TaskQueue.h

//
// Created by asalehin on 7/18/20.
//

#ifndef MODULE_NAME
#define MODULE_NAME "ThreadPool"
#endif

#include <queue>
#include <atomic>
#include <thread>
#include <functional>
#include <chrono>

using namespace std;

class TaskQueue {

public:
    TaskQueue() {
        deque<function<void()>> qu;
        q = make_unique<deque<function<void()>>>(move(qu));
        start_queue();
    }

    void stop_queue() {
        is_running = false;
    }

    void enqueue(function<void()>&& f) {
        q->push_back(move(f));
    }

    void clear_queue() {
        if (q) {
            q->clear();
        }
    }
private:
    const char* TAG = "TaskQueue:: %d";
    unique_ptr<deque<function<void()>>> q;
    atomic<bool> is_running;
    thread t;

    void start_queue() {
        is_running = true;
        t = thread([this] {
            this->executor_loop();
        });
        t.detach();
    }

    void executor_loop() {
        while (is_running) {
            if (!q->empty()) {
                auto f = q->front();
                f();
                q->pop_front();
                this_thread::sleep_for(chrono::microseconds (1000));
            }
        }
    }
};