mirror of
https://github.com/hrydgard/ppsspp.git
synced 2024-11-24 05:49:58 +00:00
138 lines
3.4 KiB
C++
138 lines
3.4 KiB
C++
// Copyright (c) 2013- PPSSPP Project.
|
|
|
|
// This program is free software: you can redistribute it and/or modify
|
|
// it under the terms of the GNU General Public License as published by
|
|
// the Free Software Foundation, version 2.0 or later versions.
|
|
|
|
// This program is distributed in the hope that it will be useful,
|
|
// but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
// GNU General Public License 2.0 for more details.
|
|
|
|
// A copy of the GPL 2.0 should have been included with the program.
|
|
// If not, see http://www.gnu.org/licenses/
|
|
|
|
// Official git repository and contact information can be found at
|
|
// https://github.com/hrydgard/ppsspp and http://www.ppsspp.org/.
|
|
|
|
#pragma once
|
|
|
|
#include "native/base/mutex.h"
|
|
#include "Core/System.h"
|
|
#include "Core/CoreTiming.h"
|
|
#include <deque>
|
|
|
|
template <typename B, typename Event, typename EventType, EventType EVENT_INVALID, EventType EVENT_SYNC, EventType EVENT_FINISH>
|
|
struct ThreadEventQueue : public B {
|
|
ThreadEventQueue() : threadEnabled_(false), eventsRunning_(false) {
|
|
}
|
|
|
|
void SetThreadEnabled(bool threadEnabled) {
|
|
threadEnabled_ = threadEnabled;
|
|
}
|
|
|
|
void ScheduleEvent(Event ev) {
|
|
{
|
|
lock_guard guard(eventsLock_);
|
|
events_.push_back(ev);
|
|
eventsWait_.notify_one();
|
|
}
|
|
|
|
if (!threadEnabled_) {
|
|
RunEventsUntil(0);
|
|
}
|
|
}
|
|
|
|
bool HasEvents() {
|
|
lock_guard guard(eventsLock_);
|
|
return !events_.empty();
|
|
}
|
|
|
|
void NotifyDrain() {
|
|
lock_guard guard(eventsLock_);
|
|
eventsDrain_.notify_one();
|
|
}
|
|
|
|
Event GetNextEvent() {
|
|
lock_guard guard(eventsLock_);
|
|
if (events_.empty()) {
|
|
NotifyDrain();
|
|
return EVENT_INVALID;
|
|
}
|
|
|
|
Event ev = events_.front();
|
|
events_.pop_front();
|
|
return ev;
|
|
}
|
|
|
|
void RunEventsUntil(u64 globalticks) {
|
|
lock_guard guard(eventsLock_);
|
|
eventsRunning_ = true;
|
|
|
|
do {
|
|
for (Event ev = GetNextEvent(); EventType(ev) != EVENT_INVALID; ev = GetNextEvent()) {
|
|
eventsLock_.unlock();
|
|
switch (EventType(ev)) {
|
|
case EVENT_FINISH:
|
|
// Stop waiting.
|
|
globalticks = 0;
|
|
break;
|
|
|
|
case EVENT_SYNC:
|
|
break;
|
|
|
|
default:
|
|
ProcessEvent(ev);
|
|
}
|
|
eventsLock_.lock();
|
|
}
|
|
|
|
// Quit the loop if the queue is drained and coreState has tripped, or threading is disabled.
|
|
if (ShouldExitEventLoop() || !threadEnabled_) {
|
|
break;
|
|
}
|
|
|
|
// coreState changes won't wake us, so recheck periodically.
|
|
if (!HasEvents()) {
|
|
eventsWait_.wait(eventsLock_);
|
|
}
|
|
} while (CoreTiming::GetTicks() < globalticks);
|
|
|
|
// This will force the waiter to check coreState, even if we didn't actually drain.
|
|
NotifyDrain();
|
|
eventsRunning_ = false;
|
|
}
|
|
|
|
// Force ignores coreState.
|
|
void SyncThread(bool force = false) {
|
|
if (!threadEnabled_) {
|
|
return;
|
|
}
|
|
|
|
lock_guard guard(eventsLock_);
|
|
// While processing the last event, HasEvents() will be false even while not done.
|
|
// So we schedule a nothing event and wait for that to finish.
|
|
ScheduleEvent(EVENT_SYNC);
|
|
while (HasEvents() && eventsRunning_ && (force || coreState == CORE_RUNNING)) {
|
|
eventsDrain_.wait_for(eventsLock_, 1);
|
|
}
|
|
}
|
|
|
|
void FinishEventLoop() {
|
|
if (threadEnabled_) {
|
|
ScheduleEvent(EVENT_FINISH);
|
|
}
|
|
}
|
|
|
|
protected:
|
|
virtual void ProcessEvent(Event ev) = 0;
|
|
virtual bool ShouldExitEventLoop() = 0;
|
|
|
|
private:
|
|
bool threadEnabled_;
|
|
bool eventsRunning_;
|
|
std::deque<Event> events_;
|
|
recursive_mutex eventsLock_;
|
|
condition_variable eventsWait_;
|
|
condition_variable eventsDrain_;
|
|
}; |