c++ - asio::io_service::strand 的正确用法？

Question

这是我的代码：

void client_connection::serve()
{
    asio::async_read(this->socket_, asio::buffer(&buffer_, buffer_.size()),

        // predicate/condition (do I wrap this?)
        std::bind(&client_connection::handle_read_predicate, this->shared_from_this(), std::placeholders::_1, std::placeholders::_2),

        // handler
        this->strand_.wrap(std::bind(&client_connection::handle_read, this->shared_from_this(), std::placeholders::_1, std::placeholders::_2)));
}

std::size_t client_connection::handle_read_predicate(const asio::error_code& error, std::size_t bytes_)
{
    // useless flawed function, for now

    // std::cout << "test: reached predicate, " << bytes_ << std::endl;

    return 0;
}

void client_connection::handle_read(const asio::error_code& error_, std::size_t bytes_)
{
    // useless flawed function, for now

    if (error_) return;

    this->serve();
}

我的问题是是否正确使用 asio::io_service::strand 来用相同的 strand_ 对象包装谓词/条件处理程序；如果是，为什么，如果不是，请解释。

Answer 1

无需将其包裹在绳索中。

根据记录的链，对于组合操作（例如async_read自由函数），所有中间处理程序都在处理程序的链中调用。这样做的副作用是所有的中间调用CompletionCondition也是从链中调用的。

但是，请确保client_connection::serve()在启动异步循环时在一个链中调度初始调用，因为初始CompletionCondition和异步读取套接字操作发生在调用者的上下文中。例如，在下图中，所有对 、 和 的调用都socket.async_read()将client_connection::handle_read_predicate()发生client_connection::handle_read()在链中：

void client_connection::start()
{
  strand_.dispatch(std::bind(&client_connection::serve,
                             shared_from_this())) --------.
}                                                         |
    .-----------------------------------------------------'
    |  .--------------------------------------------------.
    V  V                                                  |
void client_connection::serve()                           |
{                                                         |
  async_read(socket_, buffer,                             |
    std::bind(&client_connection::handle_read_predicate,  |
              this),                                      |
    strand_.wrap(                                         |
      std::bind(&client_connection::handle_read,          |
                shared_from_this())); --.                 |
}                                       |                 |
    .-----------------------------------'                 |
    V                                                     |
void client_connection::handle_read(...)                  |
{                                                         |
  if (error) return;                                      |
  serve();  ----------------------------------------------'
}