一起使用 Boost::Asio 套接字异步和同步操作

Question

我是 Boost C++ 新手，使用它来编写类似服务器的应用程序，我想知道是否可以同时使用 boost::asio::ip::tcp::socket::async_read_some(...) 和 boost::asio::ip::tcp::socket::write_some(...)。

在我的场景中，Connection 对象通过以下方式连续监听：

    void Connection::doRead()
{
    auto self(shared_from_this());
    socket_.async_read_some(boost::asio::buffer(data_rx_, max_length),
        [this, self](boost::system::error_code ec, std::size_t length)
        {
          if (!ec)
          {
              afterReading(length);
              doRead();
          }
        });
}

同时，异步函数回调（在不同的线程中运行）可以在 Connection 正在“读取”时调用 socket_.read_write。

我阅读了各种 Boost::Asio 文档，但从未涉及过这种情况。

这是允许的吗？如果没有，应该怎么做才能避免？

编辑：

按照建议，我已经阅读了各种答案，包括：Why do I need strand per connection when using boost::asio?，但仍然找不到答案，因为未指定混合异步和同步（由不同线程调用）调用是否安全。

Answer 1

不安全。

这个answer 进行了详细介绍，但总而言之，多个线程同时进行调用是不安全的，除了例外多个同步调用可能如果操作系统支持，则安全。如果一个线程在一个socket上发起异步操作，而另一个线程在同一个socket上执行同步操作，则属于前一种情况，不安全。

最优雅的解决方案是避免混合同步和异步操作。

• 如果使用同步操作并且操作系统不支持并发同步操作，则执行显式锁定，例如使用互斥锁。
• 如果使用异步操作和多线程，则使用显式 strand 来防止并发调用处理程序。

此外，通过利用 Boost.Asio 对 futures 的支持，可以同步阻止等待异步操作完成。这种方法可以允许向用户公开同步阻塞 API，但在内部使用异步操作。启动操作 (async_*) 需要在链中调用，如果调用者不在链的上下文中运行，则需要使用某种形式的同步来允许调用者等待 Asio创建未来对象。