我正在使用 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我知道在这个问题里问是不合适的,但是任何想做我正在尝试做的事情的人都可能会面临这个问题。所以如果你回答,我会很高兴。ʘ‿ʘ)
谢谢。
最佳答案
是的,您可以,只要您适本地同步对服务对象的访问(例如 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
关于c++ - boost .Asio : Could I cancel a SYNCHRONOUS operation running in a secondary thread?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/31473356/