threadPool.cpp

#include <cstddef>
#include <thread>
#include "threadPool.hpp"

agluj::ThreadPool::ThreadPool()
    : ThreadPool(std::thread::hardware_concurrency()) { }

agluj::ThreadPool::ThreadPool(std::size_t threadCount)
    : work(ioService) {
    if (threadCount == 0) {
        threadCount = 1;
    }
    for (decltype(threadCount) i = 0; i < threadCount; ++i) {
        threads.create_thread([=] {
            ioService.run();
        });
    }
}

agluj::ThreadPool::~ThreadPool() {
    ioService.stop();
    threads.join_all();
}

threadPool.hpp

#pragma once
#include <boost/asio.hpp>
#include <boost/thread.hpp>
#include <cstddef>

namespace agluj {
    class ThreadPool {
    public:
        ThreadPool();

        explicit ThreadPool(std::size_t threadCount);

        ~ThreadPool();

        template<typename F>
        void post(F function) {
            ioService.post(std::move(function));
        }

    private:
        boost::thread_group threads;
        boost::asio::io_service ioService;
        boost::asio::io_service::work work;
    };
}