使用 Boost::Asio 停止线程服务器循环

Question

我正在为一个更大的软件开发一个小型服务器循环，但它没有按我的意愿工作。

当用户输入“.quit”时，我希望软件停止这个线程服务器循环：

try {

while (true) {
      acceptor.accept(socket);
      const size_t buffersize = 1024;
      char data[buffersize+1] = {0};
      data[socket.read_some(boost::asio::buffer(data,buffersize))] = '\0'; // Write data & place terminator
      boost::thread asyncWriting(boost::bind( &myClass::writeToFile, this ));
      socket.close();
}

} catch(const boost::system::system_error& e) {
    cout << "Boost System Error: " << e.what() << endl;
}

我通过以下方式启动线程：

serverThread = boost::shared_ptr<boost::thread>( new boost::thread(boost::bind( &myClass::startServer, this )) );

但是我在停止“服务器”时遇到了问题。无论我是中断线程、关闭套接字和/或接受器还是只是中断程序 Boost 都会抛出错误：

 Bad file descriptor

它不会每次都发生，但经常发生，我想解决这个问题，而不是忽略它。

你能帮我如何关闭它clean吗？

Answer 1

服务器通常使用异步方法编写

• async_accept
• async_read
• async_write

在这种情况下，关闭所有未决异步操作的建议技术是 stop io_service 的事件处理循环。注意要特别注意~io_servicedocumentation

描述的销毁顺序 以上允许程序简化 他们的资源管理通过使用 shared_ptr。一个物体在哪里 生命周期与 a 的生命周期相关联 连接（或其他一些序列 异步操作），一个 shared_ptr 到对象将被绑定到 所有异步的处理程序 与之相关的操作。

根据您发布的问题所在的有限代码，这对我来说并不明显，我建议发布更多代码或运行您在valgrind 下拥有的代码，因为它很可能会暴露一些问题。

几天前我回复了similar question，您可能会觉得有用