C++ boost::asio::io_service创建线程池thread_group简单实例

#include 
#include 
#include 

/*
 * 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 ioService processing loop. All tasks 
 * assigned with ioService.post() will start executing. 
 */
boost::asio::io_service::work work(ioService);

/*
 * This will add 2 threads to the thread pool. (You could just put it in a for loop)
 */
threadpool.create_thread(
    boost::bind(&boost::asio::io_service::run, &ioService)
);
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"
 * You can use strand when necessary, if so, remember add "strand.h"
 */
ioService.post(boost::bind(myTask, "Hello World!"));
ioService.post(boost::bind(clearCache, "./cache"));
ioService.post(boost::bind(getSocialUpdates, "twitter,gmail,facebook,tumblr,reddit"));

/*
 * This will stop the ioService processing loop. Any tasks
 * you add behind this point will not execute.
*/
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();

boost::asio::io_service创建线程池简单实例_guotianqing的博客-CSDN博客简介boost::asio提供了一个跨平台的异步编程IO模型库，io_service类在多线程编程模型中提供了任务队列和任务分发功能。io_service最常用的接口是：run, post, stop。本文简要介绍io_service的使用，详细内容可以参阅相关reference。启动一个线程使用run()启动。run()会阻塞，直到：所有的任务已经完成并且没有任务需要分发处理...https://blog.csdn.net/guotianqing/article/details/100730340

C++ boost::thread_group 编程_那年聪聪的博客-CSDN博客_boost thread_group多线程编程https://blog.csdn.net/duan19920101/article/details/121791956