main.cpp

// Define USE_BS_THREAD_POOL to use BS::thread_pool, otherwise uses ThreadPool
// #define USE_BS_THREAD_POOL

#ifdef USE_BS_THREAD_POOL
#include "BS_thread_pool.hpp"
using Pool = BS::pause_thread_pool; // thread_pool<BS::tp::pause>
#else
#include "thread-pool.hpp"
using Pool = ThreadPool;
#endif

#include <iostream>
#include <chrono>


int main()
{
    Pool pool(4);

    for (int i = 0; i < 10; ++i) {
        pool.submit_task([i] {
            std::this_thread::sleep_for(std::chrono::milliseconds(100));
            std::cout << "Task " << i << " completed\n";
        });
    }

    std::this_thread::sleep_for(std::chrono::milliseconds(250));
    std::cout << "Pausing thread pool...\n";
    pool.pause();

    std::this_thread::sleep_for(std::chrono::milliseconds(500));
    std::cout << "Resuming thread pool...\n";
#ifdef USE_BS_THREAD_POOL
    pool.unpause();
#else
    pool.resume();
#endif

    std::this_thread::sleep_for(std::chrono::milliseconds(500));
    std::cout << "Shutting down thread pool...\n";
#ifndef USE_BS_THREAD_POOL
    pool.shutdown();
#endif
}