mirror/musikcube
1
0
Fork 0
mirror of https://github.com/clangen/musikcube.git synced 2025-04-16 14:42:41 +00:00
Code Issues Packages Projects Releases Wiki Activity

Added MessageQueue::WaitAndDispatch(), which should be usable for

Browse Source 
timer-like functionality.
This commit is contained in:
casey langen 2016-12-21 00:02:20 -08:00
parent 3aa4871e62
commit 1a00c83c7b
2 changed files with 23 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
src/musikbox/cursespp/MessageQueue.cpp
View File

@ -45,6 +45,20 @@ MessageQueue::MessageQueue() {
} }
void MessageQueue::WaitAndDispatch() {
LockT lock(this->queueMutex);
if (this->queue.size()) {
auto next = system_clock::now().time_since_epoch() - this->queue.front()->time;
waitForDispatch.wait_for(lock, next);
}
else {
waitForDispatch.wait(lock);
}
this->Dispatch();
}
void MessageQueue::Dispatch() { void MessageQueue::Dispatch() {
milliseconds now = duration_cast<milliseconds>( milliseconds now = duration_cast<milliseconds>(
system_clock::now().time_since_epoch()); system_clock::now().time_since_epoch());
@ -131,7 +145,13 @@ void MessageQueue::Post(IMessagePtr message, int64 delayMs) {
} }
} }
bool first = (curr == this->queue.begin());
this->queue.insert(curr, m); this->queue.insert(curr, m);
if (first) {
this->waitForDispatch.notify_all();
}
} }
void MessageQueue::Debounce(IMessagePtr message, int64 delayMs) { void MessageQueue::Debounce(IMessagePtr message, int64 delayMs) {

3
src/musikbox/cursespp/MessageQueue.h
View File

@ -38,6 +38,7 @@
#include "IMessageTarget.h" #include "IMessageTarget.h"
#include <mutex> #include <mutex>
#include <condition_variable>
#include <chrono> #include <chrono>
namespace cursespp { namespace cursespp {
@ -49,6 +50,7 @@ namespace cursespp {
void Remove(IMessageTarget *target, int type = -1); void Remove(IMessageTarget *target, int type = -1);
void Debounce(IMessagePtr message, int64 delayMs = 0); void Debounce(IMessagePtr message, int64 delayMs = 0);
void WaitAndDispatch();
void Dispatch(); void Dispatch();
private: private:
@ -59,6 +61,7 @@ namespace cursespp {
std::recursive_mutex queueMutex; std::recursive_mutex queueMutex;
std::list<EnqueuedMessage*> queue; std::list<EnqueuedMessage*> queue;
std::condition_variable_any waitForDispatch;
void Dispatch(IMessagePtr message); void Dispatch(IMessagePtr message);
}; };