C++ 提升 asio 多线程

Question

http://theboostcpplibraries.com/boost.asio-scalability

我正在研究 boost.asio，它引起了我的好奇心。有源（例32.3）

#include <boost/asio/io_service.hpp>
#include <boost/asio/steady_timer.hpp>
#include <chrono>
#include <thread>
#include <iostream>

using namespace boost::asio;

int main()
{
  io_service ioservice;

  steady_timer timer1{ioservice, std::chrono::seconds{3}};
  timer1.async_wait([](const boost::system::error_code &ec)
    { std::cout << "3 sec\n"; });

  steady_timer timer2{ioservice, std::chrono::seconds{3}};
  timer2.async_wait([](const boost::system::error_code &ec)
    { std::cout << "3 sec\n"; });

  std::thread thread1{[&ioservice](){ ioservice.run(); }};
//std::thread thread2{[&ioservice](){ ioservice.run(); }};
  thread1.join();
//thread2.join();
}

虽然我省略了thread2，但屏幕输出是相等的。原始示例中的线程数为 2，此源中的线程数为 1。虽然线程数是1，但是timer1和timer2是同时开始和结束的。

我想知道为什么线程数必须是两个。
谢谢您的关心！

Answer 1

该示例的重点是，您可以让多个线程调用ioservice.run() 以获得更具可扩展性的代码。对于两个线程版本，timer1 和 timer2 处理程序可能在不同的线程中处理，因此您可以获得并行性以提高性能。

正如您所展示的那样，该示例并没有很好地显示。要查看真正的区别，请尝试将此作为两个计时器的处理程序，并比较一个和两个线程版本：

timer1.async_wait([](const boost::system_error::error_code& ec) {
    std::cout << "3 sec, pausing\n";
    sleep(4);
    std::cout << "Finished pausing\n";
});