提升异步套接字和 boost::thread

Question

我正在编写 TCP 客户端，它应该能够同时发送和接收数据。 你能告诉我应该如何调用async_send 和async_receive 是单独的线程吗？

也就是说如何调用

m_Socket.async_send(boost::asio::buffer(txBuf.c_str(), txBuf.length()+1),
    boost::bind(&TCPClient::sendingHandler, this, boost::asio::placeholders::error));

m_Socket.async_receive(boost::asio::buffer(rxBuf, maxBufLen),
    boost::bind(&TCPClient::sendingHandler, this, boost::asio::placeholders::error));

在

boost::thread receivingThread(boost::bind(...));
boost::thread sendingThread(boost::bind(...));

如果我在处理程序中再次调用async_send 或async_receive，它会正常工作吗？我需要一个不定式循环来发送/接收数据。

Answer 1

主要思想是-在TCPClient::sendingHandler/receivingHandler 2io_service's 上递归发送和接收。这个 io_service's 在 2 个线程内被调用 -

boost::thread receivingThread(boost::bind(...));
boost::thread sendingThread(boost::bind(...));

这个想法在tutorial 中很明显。您必须调用和使用 2 个单独的 io_service's 的唯一区别。

另一个选项是 1 io_service 和多个调用 io_service::run 的线程。但是你必须使用boost::asio::strand远线程安全：

boost::asio::strand* _strand = new boost::asio::strand(io);
//then use it in handlers
boost::asio::async_read(*socket, 
                    boost::asio::buffer(msg.data(), result.size),
                    (*_strand).wrap(
                    boost::bind(&ConnectionInterface::parsePacket, shared_from_this(), boost::asio::placeholders::error)));