Pasted

// https://github.com/progschj/ThreadPool/blob/master/ThreadPool.h
 
#include <iostream>
#include <thread>
#include <vector>
#include <functional>
#include <condition_variable>
#include <chrono>
#include <mutex>
#include <queue>
 
 
class Executor
{
private:
    enum class ExecutorStatus {
        Work,
        Shutdown,
    };
 
public:
    explicit Executor(size_t thread_count)
        : thread_count_(thread_count)
    {
        workers_.reserve(thread_count);
        for (auto i = 0; i < thread_count; ++i) {
            workers_.emplace_back([this]{
                for (;;;) {
                    
                }
            })
        }
    }
 
    ~Executor() {
        // TODO:
    }
 
    void add_task(const std::function<void()> & function) {
        if (status_ != ExecutorStatus::Work) {
            return;
        }
 
    }
 
private:
    ExecutorStatus status_;
 
    std::mutex mutex_;
    std::condition_variable condition_;
 
    std::queue< std::function<void()> > tasks;
 
    size_t thread_count_;
    std::vector<std::thread> workers_;
};
 
int main() {
    Executor executor(5);
 
    executor.add_task([]() {
        std::cout << "Start" << std::endl;
        std::this_thread::sleep_for(std::chrono::seconds(1));
        std::cout << "Finish" << std::endl;
    });
 
    std::this_thread::sleep_for(std::chrono::seconds(3));
 
    executor.add_task([]() {
        std::cout << "Start" << std::endl;
        std::this_thread::sleep_for(std::chrono::seconds(1));
        std::cout << "Finish" << std::endl;
    });
 
    std::this_thread::sleep_for(std::chrono::seconds(10));
 
    std::cout << "Hello, World!" << std::endl;
    return 0;
}