Boost::Asio ：io_service.run() 与 poll() 或者如何在主循环中集成 boost::asio

Question

我目前第一次尝试使用 boost::asio 进行一些简单的 tcp 网络，我已经遇到了一些我不太确定如何处理的事情。据我了解 io_service.run() 方法基本上是一个循环，它运行直到没有什么可做的，这意味着它将运行直到我释放我的小服务器对象。由于我已经设置了某种主循环，为了简单起见，我宁愿从那里手动更新网络循环，而且我认为 io_service.poll() 会做我想要的事情，有点像这样

void myApplication::update()
{
     myIoService.poll();
     //do other stuff
}

：似乎有效，但我仍然想知道这种方法是否有缺点，因为这似乎不是处理 boost::asios io 服务的常用方法。这是一种有效的方法还是我应该在非阻塞额外线程中使用 io_service.run() ？

Answer 1

使用 io_service::poll 代替 io_service::run 是完全可以接受的。差异在 文档

也可以使用 poll() 函数
派遣准备好的处理程序，但是
无阻塞。

请注意，如果有任何work 留在队列中

工作类用于通知
io_service 工作开始时
完成。这确保了
io_service 对象的 run() 函数
工作正在进行时不会退出，
并且当没有时它确实退出
剩下未完成的工作。

而 io_service::poll 不会表现出这种行为，它只是调用就绪的处理程序。另请注意，您需要调用 io_service::reset 在任何后续调用 io_service:run 或 io_service::poll 时。

Answer 2

一个缺点是你会形成一个繁忙的循环。

while(true) {
    myIoService.poll()
}

将使用 100% CPU。 myIoService.run() 将使用 0% cpu。

myIoService.run_one() 可能会做你想做的事情，但如果没有什么可做的，它会阻塞。

Answer 3

像这样的循环允许您轮询，不忙等待，并根据需要重置。 （我正在使用更新的 io_context 来替换 io_service。）

while (!exitCondition) {
    if (ioContext.stopped()) {
        ioContext.restart();
    }
    if (!ioContext.poll()) {
        if (stuffToDo) {
            doYourStuff();
        } else {
            std::this_thread::sleep_for(std::chrono::milliseconds(3));
        }
    }
}