boost asio io_service::run() 是否“提前”退出？

Question

谁能告诉我boost::asio的io_service::run()方法在什么条件下会返回？的io_service::run()文档似乎表明，只要有工作要做或需要派遣处理程序，run()就不会返回。

我问这个问题的原因是我们有一个旧的 https 客户端，它联系服务器并执行 http POST。客户端中的关注点分离与我们想要的有点不同，因此我们正在更改一些内容，但我们遇到了问题。

现在，客户端基本上有一个命名错误的connect()调用，它有效地驱动了与服务器的整个协议对话。调用connect()首先创建一个boost::asio::ip::tcp::resolver对象并调用::async_resolve()它。这将启动一个链，其中asio从 asio 回调中进行新的调用。

void connect()
{
    m_resolver.async_resolve( query, bind( &clientclass::resolve_callback, this ) );
    thread = new boost::thread( bind( &boost::asio::io_service::run, m_io_service ) );
}
void resolve_callback( error_code & e, resolver::iterator i )
{
    if (!e)
    { 
        tcp::endpoint = *i;
        m_socket.lowest_layer().async_connect(endpoint, bind(&clientclass::connect_callback,this,_1,++i));
    }
}
void connect_callback( error_code & e, resolve::iterator i )
{
    if (!e)
    { 
        m_socket.lowest_layer().async_handshake(boost::asio::ssl::stream_base::client,
            bind(&clientclass::handshake_callback,this,_1,++i));
    }
}
void handshake_callback( error_code &e )
{
    if (!e)
    {
        mesg = format_hello_message();
        http_send( mesg, bind(&clientlass::hello_resp_handler,this,_1,_2) );
    }
}
void http_send( stringstream & mesg, reply_handler handler )
{
    async_write(m_socket, m_request_buffer, bind(&clientclass::write_complete_callback,this,_1,handler));
}
void write_comlete_callback( error_code &e, reply_handler handler )
{
    if (!e)
    {
        async_read_until(m_socket,m_reply_buffer,"\r\n\r\n", bind(&clientclass::handle_reply,this,handler));
    }
}
...

无论如何，这将通过协议继续进行，直到协议对话完成。从这里的代码中您可以看到，当connect()在主线程上运行时，所有后续回调和请求都会返回到在connect(). 这是“工作”代码。

当我尝试打破这条链并通过外部接口公开它时，它停止工作。特别是，我在handle_handshake()对象外部进行调用clientclass。thenhttp_send()是接口的一部分（或由外部接口调用），它创建一个新的工作线程来调用 io_service::run()。发生的情况是，即使async_write()已被调用并且尚未write_complete_callback()返回，io_service::run() 也会退出。它退出时没有错误，并声称没有调度任何处理程序，但仍然有“工作”要做？

io_service::run()所以我想知道“工作”的定义是什么？这是一个待处理的请求吗？为什么在现有代码中的请求和响应链期间它io_service::run()永远不会返回，但是当我尝试再次启动线程并启动新链时，它几乎在完成工作之前立即返回？

Answer 1

调用上下文中的工作定义run()是该 io_service 对象上的任何挂起的异步操作。这包括响应操作而调用处理程序。因此，如果一个操作的处理程序启动另一操作，则始终有可用的工作。

此外，还有一个io_service::work类可用于在 io_service 上创建工作，该工作在对象被销毁之前永远不会完成。

当单个链完成时，io_service 已完成所有异步操作，并且所有处理程序已被调用而没有启动新操作，因此它返回。在您调用 之前io_service::reset()，进一步的调用run()将返回而不执行任何操作。