在循环中调用 async_connect 时 Deadline_timer 未触发

Question

尝试以与 boost 文档建议的方式类似的方式使用deadlinetimer： https://www.boost.org/doc/libs/1_47_0/doc/html/boost_asio/example/timeouts/blocking_tcp_client.cpp

代码： JNI 线程：

HttpClient client(io_service);
client.doAsyncOperation()
io_service.run()

HttpClient：

 doAsyncOperation(){
     timer_.expires_from_now(boost::posix_time::seconds(10));
     mSocket.async_connect( endpoint,
                       boost::bind(&HttpClient::handle_connect_async, this,
                                   boost::asio::placeholders::error)

}

void HttpClient::check_deadline(){
if (timer_.expires_at() <= deadline_timer::traits_type::now())
{
    mSocket.cancel();
}else{

   timer_.async_wait(boost::bind(&SchamanHttpClient::check_deadline, this));
}

}

更新： 修复：在单独的线程上运行 io_service

所以，在 JNI 线程内部：

 HttpClient client(io_service);
 client.doAsyncOperation()
 boost::thread t(boost::bind(&boost::asio::io_service::run,&io_service));
io_service.run();
t.join();

HttpClient：

void HttpClient::check_deadline(){
if (timer_.expires_at() <= deadline_timer::traits_type::now())
{
    mSocket.cancel();
    io_service.stop();
}else{

   timer_.async_wait(boost::bind(&SchamanHttpClient::check_deadline, this));
}

Answer 1

这些例子都不再是那样了。长期以来，存在更好的界面。一定要在最新版本的 boost 中查看这些示例：

libs/asio/example/cpp03/timeouts/blocking_tcp_client.cpp
libs/asio/example/cpp11/timeouts/blocking_tcp_client.cpp

---

check_deadline() 不再被调用。怎么了？

多种可能性：

• 没有操作超时（10 秒很多）
• 你没有运行 io_service（如果你不轮询/运行任务，什么都不会发生）
• 计时器被破坏

但是，我认为最可能让您感到困惑的是：当计时器到期（超时）时，它会将其设置为永不过期：

void HttpClient::check_deadline() {
    if (timer_.expires_at() <= deadline_timer::traits_type::now()) {
        mSocket.cancel();
        timer_.expires_at(boost::posix_time::pos_infin);
    }
    timer_.async_wait(boost::bind(&HttpClient::check_deadline, this));
}

简而言之，所有这些“阻塞 IO 超时”背后的整个模式是您在每个操作之前设置超时。