asio::async_write 和 strand

Question

asio::async_write(m_socket, asio::buffer(buf, bytes),
                custom_alloc(m_strand.wrap(custom_alloc(_OnSend))));

此代码是否保证 async_write 中的所有异步操作处理程序（对 async_write_some 的调用）都是通过 strand 调用的？ （或者它只是为了my_handler？）

Answer 1

使用以下代码：

asio::async_write(stream, ..., custom_alloc(m_strand.wrap(...)));

对于这个组合操作，如果满足以下所有条件，所有对stream.async_write_some() 的调用都将在m_strand 内调用：

• 发起的async_write(...)调用在m_strand()内运行：

  assert(m_strand.running_in_this_thread());
  asio::async_write(stream, ..., custom_alloc(m_strand.wrap(...)));
  

• custom_alloc 的返回类型是：

  • 从strand::wrap()返回的确切类型

    template <typename Handler> 
    Handler custom_alloc(Handler) { ... }
    

  • 一个自定义处理程序，用于链接 asio_handler_invoke() 的调用：

    template <class Handler>
    class custom_handler
    {
    public:
      custom_handler(Handler handler)
        : handler_(handler)
      {}
    
      template <class... Args>
      void operator()(Args&&... args)
      {
        handler_(std::forward<Args>(args)...);
      }
    
      template <typename Function>
      friend void asio_handler_invoke(
        Function intermediate_handler,
        custom_handler* my_handler)
      {
        // Support chaining custom strategies incase the wrapped handler
        // has a custom strategy of its own.
        using boost::asio::asio_handler_invoke;
        asio_handler_invoke(intermediate_handler, &my_handler->handler_);
      }
    
    private:
      Handler handler_;
    };
    
    template <typename Handler>
    custom_handler<Handler> custom_alloc(Handler handler)
    {
      return {handler};
    }
    

有关股线的更多详细信息，请参阅this 答案，有关asio_handler_invoke 的详细信息，请参阅this 答案。

Answer 2

UPD：这个答案是错误的=）对于任何感兴趣的人，您可以查看 cmets 尾部的详细信息，感谢 Tanner Sansbury。

---

没有。这保证了您的 完成处理程序 将被 strand 锁调用。这不包括对async_write_some 的调用。

另外 boost::asio 没有“写队列”之类的东西，你需要管理 async_write 调用以防止写入混合内容。