moodylambdaqueue.cpp

#include "concurrentqueue.h"

moodycamel::ConcurrentQueue<function<void()>> audioThreadQueue(100);
moodycamel::ConcurrentQueue<function<void()>> uiThreadQueue(100);

void runOnAudioThread(function<void()> fn) {
	audioThreadQueue.enqueue(fn);
}

void pollAudioThreadQueue() {
	function<void()> fn;
	while(audioThreadQueue.try_dequeue(fn)) {
		fn();
	}
}

void runOnUIThread(function<void()> fn) {
	uiThreadQueue.enqueue(fn);
}

void pollUIThreadQueue() {
	function<void()> fn;
	while(uiThreadQueue.try_dequeue(fn)) {
		fn();
	}
}