2

我想在最后一个异步事件发生后延迟 n 秒后执行一次特定操作。因此，如果连续事件出现在少于 n 秒的时间内，特定的动作就会被延迟（deadline_timer 重新启动）。

我从boost deadline_timer 问题改编了计时器类，为简单起见，事件是同步生成的。运行代码，我期待类似的东西：

1 second(s)
2 second(s)
3 second(s)
4 second(s)
5 second(s)
action       <--- it should appear after 10 seconds after the last event

但我明白了

1 second(s)
2 second(s)
action
3 second(s)
action
4 second(s)
action
5 second(s)
action
action

为什么会这样？如何解决这个问题？

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

class DelayedAction
{
public:
    DelayedAction():        
        work( service),
        thread( boost::bind( &DelayedAction::run, this)),
        timer( service)
    {}

    ~DelayedAction()
    {
        thread.join();
    }

    void startAfter( const size_t delay)
    {
        timer.cancel();
        timer.expires_from_now( boost::posix_time::seconds( delay));
        timer.async_wait( boost::bind( &DelayedAction::action, this));
    }

private:
    void run()
    {
        service.run();
    }

    void action() 
    {
        std::cout << "action" << std::endl;
    }

    boost::asio::io_service         service;
    boost::asio::io_service::work   work;
    boost::thread                   thread;
    boost::asio::deadline_timer     timer;
};

int main()
{
    DelayedAction d;
    for( int i = 1; i < 6; ++i)
    {
        Sleep( 1000);
        std::cout << i << " second(s)\n";
        d.startAfter( 10);
    }
}

PS 写这篇文章，我认为真正的问题是 boost::deadline_timer 启动后如何重新启动。

4

1 回答 1

2

当您调用expires_from_now()它时，它会重置计时器，并立即使用错误代码调用处理程序boost::asio::error::operation_aborted。

如果您在处理程序中处理错误代码情况，那么您可以按预期工作。

void startAfter( const size_t delay)
{
    // no need to explicitly cancel
    // timer.cancel();
    timer.expires_from_now( boost::posix_time::seconds( delay));
    timer.async_wait( boost::bind( &DelayedAction::action, this, boost::asio::placeholders::error));
}

// ...

void action(const boost::system::error_code& e) 
{
    if(e != boost::asio::error::operation_aborted)
        std::cout << "action" << std::endl;
}

这在文档中进行了讨论：http: //www.boost.org/doc/libs/1_47_0/doc/html/boost_asio/reference/deadline_timer.html

具体参见标题为：更改活动截止日期计时器的到期时间的部分

于 2012-08-09T16:44:58.787 回答