Почему функция boost asio истекает_с_сейчас()и отменяет установленный_таймер?

При попытке (не установить! )текущее время истечения срока действия с использованием boost expires_from_now()похоже фактически отменяет таймер, однако на самом деле он работает, как и ожидалось, но, в конце концов, не вызывает обработчик.

Или, другими словами, при доступе к крайнему_таймеру с истекающим_с_сейчас()он вызовет обработчик немедленно и не вызовет обработчик по истечении срока его действия.

Обратите внимание на следующий код и соответствующий вывод:

#include <boost/asio.hpp> 
#include <boost/thread.hpp> 
#include <boost/date_time/posix_time/posix_time.hpp>
#include <boost/date_time/posix_time/posix_time_io.hpp>
#include <iostream> 

using namespace boost::posix_time;
using namespace std;

void handler1(const boost::system::error_code &ec) 
{ 
    if (ec == boost::asio::error::operation_aborted)
    {
        std::cout << microsec_clock::local_time() << " Handler1: Timer 1 was cancelled or retriggered." << std::endl; 
    }
    else
    {
        std::cout << microsec_clock::local_time() << " Handler1: expired." << std::endl; 
    }
} 

boost::asio::io_service io_service1; 

class Mytimer {
public:
    Mytimer();
    void startTimer();
    void runTimerThread();
    bool isRunning();
private:
    bool m_isRunning;
    boost::asio::deadline_timer* m_pTimer;
    boost::thread* m_pThread;
};

Mytimer::Mytimer()
  : m_pTimer(NULL),
    m_pThread(NULL)
{
    m_pTimer = new boost::asio::deadline_timer(io_service1); 
    m_pTimer->async_wait(handler1); 
}

void Mytimer::runTimerThread()
{
    io_service1.run();
}

void Mytimer::startTimer()
{
    m_pThread = new boost::thread(&Mytimer::runTimerThread, this);
    m_pTimer->expires_from_now(boost::posix_time::seconds(10));
}

bool Mytimer::isRunning()
{

    time_duration td = m_pTimer->expires_from_now();
    if (td.total_seconds() > 0)
    {
        return true;
    }
    return false;
}

int main() 
{ 
    time_facet *facet = new time_facet("%Y%m%d %H:%M:%S%f");
    std::cout.imbue(std::locale(std::cout.getloc(), facet));

    cout << microsec_clock::local_time() << " before timer construction" << endl;
    Mytimer timer;
    cout << microsec_clock::local_time() << " before startTimer()" << endl;
    timer.startTimer();
    cout << microsec_clock::local_time() << " IsRunning: " << timer.isRunning() << endl;
    for (int i = 0; i <= 20; i++)
    {
        sleep(1);
        cout << microsec_clock::local_time() << " IsRunning: " << timer.isRunning() << endl;
    }
} 

20120412 22:41:45689235 перед построением таймера
20120412 22:41:45689514 до startTimer()
20120412 22:41:45689619 IsRunning:1
20120412 22:41:45689693 Обработчик 1:Таймер 1 был отменен или запущен повторно.
20120412 22:41:46689792 Выполняется:1
20120412 22:41:47689994 Выполняется:1
20120412 22:41:48690179 Выполняется:1
20120412 22:41:49690375 Выполняется:1
20120412 22:41:50690530 Выполняется:1
20120412 22:41:51690712 Выполняется:1
20120412 22:41:52690884 Выполняется:1
20120412 22:41:53691069 Выполняется:1
20120412 22:41:54691236 Выполняется:0
20120412 22:41:55691428 Выполняется:0
20120412 22:41:56691614 Выполняется:0
20120412 22:41:57691810 Выполняется:0
20120412 22:41:58692001 Выполняется:0
20120412 22:41:59692193 Выполняется:0
20120412 22:42:00692364 Выполняется:0
20120412 22:42:01692542 Выполняется:0
20120412 22:42:02692706 Выполняется:0
20120412 22:42:03692886 Выполняется:0
20120412 22:42:04693071 Выполняется:0
20120412 22:42:05693267 Выполняется:0
20120412 22:42:06693465 IsRunning:0

8
задан ildjarn 12 April 2012 в 20:52
поделиться