9

看了boost::asio的文档，还是不清楚什么时候需要用到asio::strand。假设我有一个使用 io_service 的线程，那么在套接字上写入是否安全，如下所示？

void Connection::write(boost::shared_ptr<string> msg)
{
    _io_service.post(boost::bind(&Connection::_do_write,this,msg));
}

void Connection::_do_write(boost::shared_ptr<string> msg)
{
    if(_write_in_progress)
    {
      _msg_queue.push_back(msg);
    }
    else
    {
      _write_in_progress=true;
      boost::asio::async_write(_socket, boost::asio::buffer(*(msg.get())),
      boost::bind(&Connection::_handle_write,this,
             boost::asio::placeholders::error));
    }
}

void Connection::_handle_write(boost::system::error_code const &error)
{
  if(!error)
  {
    if(!_msg_queue.empty())
    {
          boost::shared_ptr<string> msg=_msg_queue.front();
      _msg_queue.pop_front();
      boost::asio::async_write(_socket, boost::asio::buffer(*(msg.get())),
           boost::bind(&Connection::_handle_write,this,
                   boost::asio::placeholders::error));
        }
    else
    {
      _write_in_progress=false;
    }
  }
}

多个线程调用 Connection::write(..) 还是我必须使用 asio::strand ？

4

2 回答 2

22

strand简短回答：不，在这种情况下您不必使用 a 。

广泛简化，anio_service包含函数对象（处理程序）的列表。post()当在服务上调用时，处理程序被放入列表中。例如，每当异步操作完成时，处理程序及其参数都会放入列表中。 io_service::run()一个接一个地执行一个处理程序。run()因此，如果在您的情况下只有一个线程调用，则没有同步问题，也不strand需要 s。
只有当多个线程调用run()同一个io_service时，才会同时执行多个处理程序，在 N 个线程中最多 N 个并发处理程序。如果这是一个问题，例如，如果队列中可能同时有两个处理程序访问同一个对象，则需要strand.
你可以看到strand作为一组处理程序的一种锁。如果线程执行与 a 关联的处理程序strand，则该处理程序将strand被锁定，并在处理程序完成后被释放。任何其他线程只能执行与锁定无关的处理程序strand。

注意：这个解释可能过于简单并且在技术上不准确，但它给出了io_service在 s 和strands 中发生的事情的基本概念。

于 2013-05-06T11:51:30.703 回答
4

仅从一个线程调用io_service::run()将导致所有事件处理程序在线程内执行，无论有多少线程正在调用Connection::write(...). 因此，在处理程序不可能并发执行的情况下，它是安全的。文档将此称为隐式 strand。

另一方面，如果多个线程都在调用io_service::run()，则需要一个 strand 。 这个答案更详细地涵盖了链。

于 2013-05-09T19:04:54.280 回答