boost::threadpool简单实例

#include <boost/asio/io_service.hpp>
#include <boost/bind.hpp>
#include <boost/thread/thread.hpp>


void task_1(int num)
{
    for (int i = 0; i < 5; i ++)
        std::cout << "task_1 " << i << std::endl;
}

void task_2(int num)
{
    for (int i = 0; i < 5; i ++)
        std::cout << "task_2 " << i << std::endl;
}

int main()
{
    
    /*
     * Create an asio::io_service and a thread_group (through pool in essence)
     */
    boost::asio::io_service ioService;
    boost::thread_group threadpool;


    /*
     * This will start the io_service processing loop. All tasks
     * assigned with io_service.post() will start executing.
     */
    boost::asio::io_service::work* work;

    /*
     * This will add 2 threads to the thread pool. (You could just put it in a for loop)
     */
    int thread_count = 2;
    for (int i = 0; i < thread_count; ++ i)
        threadpool.create_thread(boost::bind(&boost::asio::io_service::run, &ioService));
    
    /*
     * This will assign tasks to the thread pool.
     * More about boost::bind: "http://www.boost.org/doc/libs/1_54_0/libs/bind/bind.html#with_functions"
     */
    ioService.post(boost::bind(task_1, 111));
    ioService.post(boost::bind(task_2, 222));

    /*
     * This will stop the ioService processing loop. Any tasks
     * you add behind this point will not execute.
     */
    sleep(1);
    ioService.stop();

    /*
     * Will wait till all the threads in the thread pool are finished with
     * their assigned tasks and 'join' them. Just assume the threads inside
     * the threadpool will be destroyed by this method.
     */
    threadpool.join_all();
    
    return 0;
}