使用多线程的 boost 异步 API

Question

关于这篇文章： Why do I need strand per connection when using boost::asio?

我关注的是关于异步调用的声明： "但是，多个线程并发调用是不安全的"

这个例子： http://www.boost.org/doc/libs/1_55_0/doc/html/boost_asio/example/cpp11/chat/chat_client.cpp

如果我将 main 称为“线程 1”并将衍生线程 t 称为“线程 2”，那么似乎线程 1 正在调用 async_write（假设没有 write_in_progress），而线程 2 正在调用 async_read。我错过了什么？

Answer 1

在官方chat example 中，chat_client::write() 通过io_service::post() 将工作推迟到io_service，这将：

• 请求io_service通过当前正在调用io_service上的poll()、poll_one()、run()或run_one()函数的线程执行给定的处理程序
• 不允许在调用函数中调用给定的处理程序（例如chat_client::write()）

由于只有一个线程在运行io_service，并且所有套接字读取、写入和关闭操作都仅从已发布到io_service 的处理程序中启动，因此程序满足@987654323 的线程安全要求@。

class chat_client
{
  void write(const chat_message& msg)
  {
    // The nullary function `handler` is created, but not invoked within
    // the calling function.  `msg` is captured by value, allowing `handler`
    // to append a valid `msg` object to `write_msgs_`.
    auto handler = [this, msg]()
      {
        bool write_in_progress = !write_msgs_.empty();
        write_msgs_.push_back(msg);
        if (!write_in_progress)
        {
          do_write();
        }
      };

    // Request that `handler` be invoked within the `io_service`.
    io_service_.post(handler);
  }
};