Quando provo a ottenere (non impostato!) Il tempo di scadenza corrente utilizzando il boost expires_from_now() di sembra effettivamente annullare il timer, ma effettivamente viene eseguito come previsto, ma alla fine non chiama il gestore.Perché la funzione asio boost expires_from_now() annulla un deadline_timer?
In altre parole, quando si accede a un deadline_timer con expires_from_now() chiamerà immediatamente il gestore e non chiamerà il gestore quando scade.
Risparmi il seguente codice ed corrispondente uscita:
#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: 45.689.235 prima costruzione timer
20.120.412 22: 41: 45.689.514 prima startTimer()
20.120.412 22:41: 45689619 IsRunning: 1
20120412 22: 41: 45689693 Handler1: il timer 1 è stato annullato o riattivato.
20.120.412 22: 41: 46.689.792 IsRunning: 1
20.120.412 22: 41: 47.689.994 IsRunning: 1
20.120.412 22: 41: 48.690.179 IsRunning: 1
20.120.412 22: 41: 49.690.375 IsRunning: 1
20.120.412 22:41 : 50690530 IsRunning: 1
20.120.412 22: 41: 51.690.712 IsRunning: 1
20.120.412 22: 41: 52.690.884 IsRunning: 1
20.120.412 22: 41: 53.691.069 IsRunning: 1
20.120.412 22: 41: 54.691.236 IsRunning: 0
20120412 22: 41: 55691428 IsRunning: 0
20.120.412 22: 41: 56.691.614 IsRunning: 0
20.120.412 22: 41: 57.691.810 IsRunning: 0
20.120.412 22: 41: 58.692.001 IsRunning: 0
20.120.412 22: 41: 59.692.193 IsRunning: 0
20.120.412 22:42 : 00692364 IsRunning: 0
20.120.412 22: 42: 01.692.542 IsRunning: 0
20.120.412 22: 42: 02.692.706 IsRunning: 0
20.120.412 22: 42: 03.692.886 IsRunning: 0
20.120.412 22: 42: 04.693.071 IsRunning: 0
20120412 22: 42: 05693267 IsRunning: 0
20.120.412 22: 42: 06.693.465 IsRunning: 0
Penso che ci siano due problemi qui: prima nel costruttore il timer viene chiamato senza alcuna scadenza, quindi in realtà scadrà immediatamente. Secondo quando la funzione membro riavvia il timer, non vi è alcun gestore. Quindi expires_from_now funziona ancora (come puoi vedere le 1 modifiche a 0 dopo 10 secondi), ma il gestore non verrà mai chiamato, perché non ne è associato nessuno. –
Terrò la domanda aperta per ora, forse qualcuno può confermare le mie conclusioni. –
+1 per il riproduttore –