boost asio async_read_some timeout

boost asio async_read_some timeout

本文关键字:some timeout read boost async asio      更新时间:2023-10-16

我使用 async_read_some与超时使用此代码

        readdata=0;
        port_->async_read_some(boost::asio::buffer(vector),
                boost::bind(readCallback));

        //init async timer
        boost::asio::deadline_timer timer(io);
        timer.async_wait(boost::bind(timeoutHandler));
        timer.expires_from_now(boost::posix_time::seconds(5));
        io.reset();
        do {
            io.run_one();
        }
        while (readdata==0);

这是我的回调

void readCallback()
{
    std::cout << "READ CALLBACK: "<<x<<std::endl;
    readdata=1;
    return;
}
void timeoutHandler()
{
   std::cout << "TIMEOUT CALLBACK: "<<x<<std::endl;
   readdata=1;
}

我的问题是,Timeouthandler是立即执行的,而不是5秒后

简单错误。您应该在致电async_wait之前进行expires_from_now

#include <iostream>
#include <asio.hpp>
#include <boost/date_time/posix_time/posix_time.hpp>
int main() {
  asio::io_service io_s;
  asio::deadline_timer timer(io_s);
  timer.expires_from_now(boost::posix_time::seconds(5));
  timer.async_wait([](auto err_c) { std::cout << "After 5 seconds" << std::endl; } );
  io_s.reset();
  io_s.run();
  return 0;
}