pgLab/core/WorkManager.cpp

#include "WorkManager.h"

#include <QRunnable>
#include <QThreadPool>
#include <deque>
#include <functional>
#include <mutex>


class WorkManagerImpl: public WorkManager {
public:
	void addRunnable(QRunnable *runnable) override;
	void addWork(Work work) override;
};



std::shared_ptr<WorkManager> WorkManager::getWorkManager()
{
	static std::shared_ptr<WorkManager> wm = std::make_shared<WorkManagerImpl>();
	return wm;
}

void WorkManagerImpl::addRunnable(QRunnable *runnable)
{
	auto tp = QThreadPool::globalInstance();
	tp->start(runnable);
}

class CallableTask : public QRunnable {
public:
	CallableTask(WorkManager::Work &&w)
		: work(std::move(w))
	{}
protected:
	void run() final
	{
		work();
	}
private:
	WorkManager::Work work;
};

void WorkManagerImpl::addWork(Work work)
{
	addRunnable(new CallableTask(std::move(work)));
}