boost deadline_timer不等待

我试过在这个简单的测试应用程序中使用boost deadline_timer，但遇到了一些麻烦。目标是定时器使用deadline_timer的expires_at()成员函数每45毫秒触发一次。（我需要一个绝对的时间，所以我不考虑expires_from_now()。我现在也不关心漂移）。当我运行该程序时，wait()不会等待45毫秒！然而，没有错误报道。我以某种方式错误地使用图书馆？boost deadline_timer不等待

样例程序：

#include <boost/asio.hpp> 
#include <boost/thread.hpp> 
#include <boost/bind.hpp> 
#include <boost/date_time/posix_time/posix_time.hpp> 
#include <iostream> 
using namespace std; 

int main() 
{ 
     boost::asio::io_service Service; 
     boost::shared_ptr<boost::thread> Thread; 
     boost::asio::io_service::work RunForever(Service); 
     Thread = boost::shared_ptr<boost::thread>(new boost::thread(boost::bind(&boost::asio::io_service::run, &Service))); 
     boost::shared_ptr<boost::asio::deadline_timer> Timer(new boost::asio::deadline_timer(Service)); 

     while(1) 
     { 
       boost::posix_time::time_duration Duration; 
       Duration = boost::posix_time::microseconds(45000); 
       boost::posix_time::ptime Start = boost::posix_time::microsec_clock::local_time(); 
       boost::posix_time::ptime Deadline = Start + Duration; 
       boost::system::error_code Error; 
       size_t Result = Timer->expires_at(Deadline, Error); 
       cout << Result << ' ' << Error << ' '; 
       Timer->wait(Error); 
       cout << Error << ' '; 
       boost::posix_time::ptime End = boost::posix_time::microsec_clock::local_time(); 
       (cout << "Duration = " << (End - Start).total_milliseconds() << " milliseconds" << endl).flush(); 
     } 
     return 0; 
}

来源

2011-03-21 Dylan Klomparens

您正在混合当地时间与系统时间。 asio比较你的本地时间的时间很可能是你希望截止日期设置的时间之后的几个小时，所以等待立即返回（取决于你住的地方;同样的代码也可能等待几个小时）。为了避免这种混淆，绝对时间应该来自asio :: time_traits。

#include <boost/asio.hpp> 
#include <boost/asio/time_traits.hpp> 
#include <boost/thread.hpp> 
#include <boost/bind.hpp> 
#include <boost/date_time/posix_time/posix_time.hpp> 
#include <iostream> 
using namespace std; 

typedef boost::asio::time_traits<boost::posix_time::ptime> time_traits_t; 
int main() {   
    boost::asio::io_service Service;   
    boost::shared_ptr<boost::thread> Thread;   
    boost::asio::io_service::work RunForever(Service);   
    Thread = boost::shared_ptr<boost::thread>(new boost::thread(boost::bind(&boost::asio::io_service::run, &Service))); 
    boost::shared_ptr<boost::asio::deadline_timer> Timer(new boost::asio::deadline_timer(Service));   
    while(1)   
    {     
     boost::posix_time::time_duration Duration; 
     Duration = boost::posix_time::microseconds(45000); 
     boost::posix_time::ptime Start = time_traits_t::now(); 
     boost::posix_time::ptime Deadline = Start + Duration; 
     boost::system::error_code Error; 
     size_t Result = Timer->expires_at(Deadline, Error); 
     cout << Result << ' ' << Error << ' '; 
     Timer->wait(Error); 
     cout << Error << ' '; 
     boost::posix_time::ptime End = boost::posix_time::microsec_clock::local_time(); 
     (cout << "Duration = " << (End - Start).total_milliseconds() << " milliseconds" << endl).flush(); 
    }   
    return 0; 
}

在这种情况下应该适合您。

来源

2011-03-22 01:48:13 ltc

你混合异步方法io_service::run与同步方法deadline_timer::wait。这不起作用。请使用deadline_timer::async_wait和io_service::run，或跳过io_service::run，只使用deadline_timer::wait。你也不需要一个线程来调用io_service:run如果你走异步路由，一个线程就可以做得很好。这两个概念在Asio tutorial的基本技能部分中有详细说明。

void print(const boost::system::error_code& /*e*/) 
{ 
    std::cout << "Hello, world!\n"; 
} 

int main() 
{ 
    boost::asio::io_service io; 

    boost::asio::deadline_timer t(io, boost::posix_time::seconds(5)); 
    t.async_wait(print); 
    io.run(); 

    return 0; 
}

注意，你需要给一些工作你io_service之前调用run()的服务。在这个例子中，async_wait就是这样的工作。

潜在无关：45ms是一个相当小的三角洲。根据我的经验，任何处理器通过Asio epoll反应堆队列所需的最短时间大约为30毫秒，在较高负载情况下，这可能会相当长。虽然这在很大程度上取决于您的应用程序

来源

2011-03-22 00:46:34

boost deadline_timer不等待

回答

相关问题