c++ - boost .Asio : Could I cancel a SYNCHRONOUS operation running in a secondary thread?

Question

我正在使用 Boost.Asio 和 Boost.Thread。如何取消辅助线程中的同步 IO 操作？例如，

/* consider needed headers included and typedefs are defined */

void OperationThread(sock_ptr sock) {
  char buf[128];
  boost::system::error_code ec;
  boost::asio::read(*sock, boost::asio::buffer(buf, 128), ec);
}

void AcceptorThread() {
  boost::asio::io_service serv;
  boost_asio_endpoint_type ep( ... /* v4() etc. */ , ... /* port */ );
  boost_asio_acceptor_type acc(serv, ep);
  sock_ptr sock(new boost_asio_socket_type(serv));
  while (true) {
    acc.accept(*sock);
    boost::thread t(boost::bind(&OperationThread, sock)); // new thread
    sock.reset(new boost_asio_socket_type(serv)); // new socket
  }
}

int main() {
  boost::thread accthread(&AcceptorThread);
  cin.get();
  // Code to cancel synchronous accept operation and read operations
  return 0;
}

sock_ptr是 boost::shared_ptr<boost_asio_socket_type> 的类型定义.

如果您对 boost_asio_*_type 感到困惑考虑它们是为 boost::asip::ip::tcp 配置的和 v4() .

首先我曾经使用异步操作。但是您知道它们有点难以管理。我想要每个连接一个线程的应用程序模型。使用异步IO更难实现(其实我也不知道怎么实现，如何在一个线程中轮询具体的异步操作？，如果你提到我会很高兴。)。所以我使用同步IO。

在我的代码中，正如您所注意到的，我的线程对象在 while block 的末尾被销毁。它有什么害处吗？ (sorry我知道在这个问题里问是不合适的，但是任何想做我正在尝试做的事情的人都可能会面临这个问题。所以如果你回答，我会很高兴。ʘ‿ʘ)

谢谢。

Answer 1

是的，您可以，只要您适本地同步对服务对象的访问(例如 boost::asio::ip::tcp::socket 或 boost::asio::deadline_timer)¹。

此外，在您的代码中，您将使用 shared_ptr<>来自不同的线程。共享指针本身不是线程安全的。尽管您可以使用 the atomic_load and atomic_store functions与他们一起使其成为线程安全的。

---

¹ 文档揭示了对象是线程安全的(异常(exception))情况。我能从内存中引用的唯一两个是 boost::asio::io_service和 boost::asio::strand