主页 / 问题 / 1559025
Accepted
typemoon
Asked:2023-12-26 20:35:02 +0800 CST2023-12-26 20:35:02 +0800 CST

boost::asio 定时器的奇怪行为

  • 772

boost 文档有以下示例代码：

#include <iostream>
#include <boost/asio.hpp>
#include <boost/bind.hpp>

using namespace boost;

void print(const system::error_code& e, asio::steady_timer* timer, int count)
{
    if (count < 5)
    {
        std::cout << count << std::endl;
        ++count;
        timer->expires_at(timer->expiry() + asio::chrono::seconds(1));
        timer->async_wait(boost::bind(print, asio::placeholders::error, timer, count));
    }
}

int main()
{
    asio::io_context io;
    int count = 0;
    asio::steady_timer t(io, asio::chrono::seconds(1));
    t.async_wait(bind(print, asio::placeholders::error, &t, count));
    io.run();
    return 0;
}

这里，在 main 函数中，定时器的初始值是 5 秒：

asio::steady_timer t(io, asio::chrono::seconds(5));

这个初始值有什么用呢？我注意到，如果去掉这个参数，即这样做：

asio::steady_timer t(io);

那么计时器会立即显示从 0 到 5 的所有值，而不是每秒一次。为什么会有这种行为？为什么定时器需要有一个初始值才能每秒输出一次值？

c++

1 个回答

  1. Best Answer

    定时器具有三种类型的构造函数：

    1. 采取绝对响应时间。
    2. 获取相对响应时间（相对于当前响应时间）。
    3. 不设定时间。假设响应时间将稍后设置。

    asio::steady_timer t(io, asio::chrono::seconds(5));属于第二类，而asio::steady_timer t(io);第三类，但是，您没有设置响应时间，它仍然等于时钟的开始时间，因此事实证明它在创建时已经过期。通过在调用处理程序时在时钟的开头添加一秒（而不是当前时间），您还可以获得已经过期的时间点。如果你正常编写处理程序，你可以更清楚地理解发生了什么：

    #include <boost/asio.hpp>
#include <boost/bind.hpp>

#include <chrono>
#include <iostream>

void print(::boost::system::error_code const & ec, ::boost::asio::steady_timer* timer, int count)
{
    auto const when{::std::chrono::time_point_cast<::std::chrono::seconds>(timer->expires_at()).time_since_epoch()};
    auto const now{::std::chrono::time_point_cast<::std::chrono::seconds>(::std::chrono::steady_clock::now()).time_since_epoch()};
    ::std::cout << "invoked at " << now << ", target " << when << "\n";
    if (ec)
    {
        if (::boost::asio::error::operation_aborted == ec)
        {
            ::std::cout << "timer cancelled\n";
        }
        else
        {
            ::std::cout << "timer error " << ec << "\n";
        }
    }
    else
    {
        if (when <= now)
        {
            ::std::cout << "timeout\n";
            std::cout << count << "\n";
            ++count;
            if (count < 5)
            {
                timer->expires_at(timer->expiry() + ::boost::asio::chrono::seconds{1});
                timer->async_wait(::boost::bind(&::print, ::boost::asio::placeholders::error, timer, count));
            }
        }
        else
        {
            ::std::cout << "misfire\n";
        }
    }
}

int main()
{
    ::boost::asio::io_context io{};
    int count{};
    ::boost::asio::steady_timer t{io/*, ::boost::asio::chrono::seconds{1}*/};
    t.async_wait(::boost::bind(&::print, ::boost::asio::placeholders::error, &t, count));
    io.run();
    return 0;
}

    在 8969s 调用，目标 0s
    超时
    0
    在 8969s 调用，目标 1s
    超时
    1
    在 8969s 调用，目标 2s
    超时
    2
    在 8969s 调用，目标 3s
    超时
    3
    在 8969s 调用，目标 4s
    超时
    4

    在线编译器

    • 1

相关问题