WorkerThread.h

Go to the documentation of this file.

#pragma once

#include <deque>
#include <mutex>
#include <condition_variable>
#include <thread>

#include "Task.h"

class WorkerThread
{
public:
    WorkerThread();
    ~WorkerThread();
    void runOnWorker(Task *task);

private:
    void workerThreadRunner();

    std::thread workerThread;
    std::mutex taskDequeMutex;
    std::condition_variable cv;
    std::deque<Task *> taskDeque;
    bool isRunning = true;
};