task_queue.h

Go to the documentation of this file.

#pragma once

 
#include <functional>
#include <mutex>
#include <queue>
#include <thread>
 
namespace satdump
{
    class TaskQueue
    {
    private:
        std::thread task_thread;
        std::mutex queue_mtx;
        std::queue<std::function<void()>> task_queue;
 
        bool thread_exited = true;
 
    private:
        void threadFunc();
 
    public:
        TaskQueue();

        ~TaskQueue();

        void push(std::function<void()> task);
    };
} // namespace satdump