async_worker.h

#pragma once
#include <thread>
#include "blocking_queue.h"
#include "type_aliases.h"
 
namespace cl::threading {
    class async_worker {
    private:
        bool running {false};
        std::thread worker_thread;
        blocking_queue<std::unique_ptr<async_task>> queue;
        void process();
 
    public:
        async_worker();
 
        void start();
        void stop();
        void schedule(std::unique_ptr<async_task> task);
    };
}