ThreadPool.h

#pragma once
 
// Standard.
#include <atomic>
#include <functional>
#include <mutex>
#include <queue>
#include <condition_variable>
 
namespace ne {
    class ThreadPool {
    public:
        ThreadPool();
 
        ThreadPool(const ThreadPool&) = delete;
        ThreadPool& operator=(const ThreadPool&) = delete;
 
        ~ThreadPool();
 
        void addTask(const std::function<void()>& task);
 
        void stop();
 
    protected:
        void processTasksThread();
 
    private:
        std::condition_variable cvNewTasks;
 
        std::vector<std::thread> vRunningThreads;
 
        std::pair<std::mutex, std::queue<std::function<void()>>> mtxTaskQueue;
 
        std::atomic_flag bIsShuttingDown;
 
        const unsigned int iMinThreadCount = 4;
    };
} // namespace ne