ThreadPool.h

Go to the documentation of this file.

 
#pragma once
#include <condition_variable>
#include <functional>
#include <mutex>
#include <queue>
#include <vector>
#include <thread>
 
class ThreadPool {
    private:
        std::vector<std::thread> workers;
        std::queue<std::function<void()>> tasks;
        std::mutex queue_mutex;
        std::condition_variable condition;
        bool stop;
    public:
        ThreadPool(size_t threads = std::thread::hardware_concurrency());
        ~ThreadPool();
 
        void enqueue(std::function<void()> task);
        void cleanup();
        size_t getThreadCount() const;
};