asio链和数据同步

Question

我发现 asio 关于strand 同步的文档是晦涩难懂的。它只是说在线程池设计 asio 应用程序中，处理程序可以在任何调用 io_service::run() 的线程中运行。使用strand 扭曲这些处理程序可以使它们的执行正确并发。在其example3中，所有handle_read都被strand包裹，我认为Connection类中的变量如buffer已经被strand同步，不同的线程调用handle_read会起来-最新数据，没关系。但是在Connection 类中定义的一个数据成员也被处理程序访问但未被strand 包装呢？我认为这是一个问题，不是吗？

在其文档example3 中，为什么handle_accept 没有被strand 包裹？ new_connection_ 由多线程访问：new_connection_.reset 由线程 A 调用，server::handle_accept 由线程 B 调用。我认为它需要在这里进行数据同步，否则线程 B 可能会使用其过期的 new_connection_尚未调用 reset。

Answer 1

HTTP Server 3 的设计方式使其实际上不需要strand。

Boost.Asio 的一个基本特征是，对于给定的操作，处理程序最多会被调用一次。这种行为允许将异步编程的调用路径更多地设想为调用链。

例如，检查server 接受连接的图示调用链：

server::server(...)
{
  start_accept();  --.
}                    |
    .----------------'
    |      .----------------------------------------.
    V      V                                        |
void server::start_accept()                         |
{                                                   |
  new_connection_.reset(new connection(...));       |
  acceptor_.async_accept(..., handle_accept);  --.  |
}                                                |  |
    .--------------------------------------------'  |
    |                                               |
    V                                               |
void server::handle_accept(...)                     |
{                                                   |
  if (!error)                                       |
  {                                                 |
    new_connection_->start();                       |
  }                                                 |    
  start_accept();  ---------------------------------'
}

如图所示，仅存在一个异步事件链。在new_connection 上不可能同时执行处理程序或操作，据说它在隐式链中运行。处理程序server::handle_accept 运行的线程无关紧要。

this 问题中回答了 connection::handle_read 调用链和有关 strand 的更多详细信息。

Answer 2

我认为您在某种程度上错过了 strand 的含义。 它不同步数据访问。它同步处理程序调用。这可以理解为“所有被给定的strand包裹的处理程序都不会被同时调用”。

所以，您的第一个问题是：如果某些处理程序没有被 strand 包裹 - 现在可以同时调用它。因此它会受到同步问题和/或 RC 的影响。请注意，如果您包裹在一个地方并不意味着您受到 RC 的保护；这应该在每次通话中完成。因为 strand 不知道你从其他线程调用了什么，除非你使用 .wrap

第二个问题：在给定示例 start_accept 中设置接受处理程序 handle_accept，而 handle_accept 正在设置新的接受处理程序（通过调用 start_accept）。因此，它们不会被同时调用，因为您不能创建 2 个或更多 async_accept 事件。当然，如果其他线程为同一个“服务器”实例调用 start_accept - 此示例可能/将会失败，但这样做显然是错误的。