boost::asio io_service 线程池

Question

为 io_service 设置线程池的正确用法是什么？来自documentation 的这两条语句让我大吃一惊：

io_service::run

run() 函数的正常退出意味着 io_service 对象已停止（stopped() 函数返回 true）。除非之前调用了 reset()，否则对 run()、run_one()、poll() 或 poll_one() 的后续调用将立即返回。

io_service::reset

当由于 io_service 被停止或这些函数的先前调用返回时，必须在 run()、run_one()、poll() 或 poll_one() 函数的任何第二组或以后的调用之前调用此函数没工作了。

这是我目前正在做的事情：

boost::thread_group     m_Threads;
boost::asio::io_service m_IoService;
boost::barrier          m_Barrier(numThreads);

for( unsigned int i = 0; i < numThreads; ++i )
{
    m_Threads.create_thread(
        [&]()
        {
            for(;;)
            {
                m_IoService.run();

                if( m_Barrier.wait() )  //  will only return true for 1 thread
                {
                    m_IoService.reset();
                }
                m_Barrier.wait();
            }
        });
}

m_IoService.stop();
m_Threads.interrupt_all();
m_Threads.join_all();

如果我只是将m_IoService.run() 放入无限循环中，一切似乎都可以正常工作（文档似乎表明不是应该是这种情况）。 正确的方法是什么？

Answer 1

run() 是一个阻塞调用，将在返回之前执行它可以执行的所有事件。只有在没有更多事件需要处理时才会返回。一旦返回，您必须在 io_service 上调用reset()，然后再调用run()。

您可以有多个线程调用run() - 这不是问题，只要 io_service 有一些工作要做，您就不需要无限循环。正常的模式是在 io_service 上创建一个 work 对象，这将强制 run() 永远不会返回。这确实意味着您必须在完成后显式调用 io_service 上的stop()，因为它永远不会自然退出。

如果您在 io_service 上设置work，它永远不会自然退出，因此您永远不需要调用reset()。

work some_work(m_IoService); // this will keep the io_service live.

for( unsigned int i = 0; i < numThreads; ++i )
{
  m_Threads.create_thread(
    [&]()
    {
      m_IoService.run();
    });
}

现在所有线程都在 io_service 上调度事件

// Now post your jobs
m_IoService.post(boost::bind(...)); // this will be executed in one of the threads
m_IoService.post(boost::bind(...)); // this will be executed in one of the threads
m_IoService.post(boost::bind(...)); // this will be executed in one of the threads

m_IoService.stop(); // explicitly stop the io_service
// now join all the threads and wait for them to exit