Pourquoi ne boost asio fonction expires_from_now() annuler un deadline_timer?
Lorsque j'essaie de l'obtenir (pas ensemble!) la date d'expiration actuelle de temps à l'aide de
boost expires_from_now() est semble effectivement annuler la minuterie,
pourtant, il fonctionne en fait comme prévu, mais n'a finalement pas l'appel du gestionnaire.
Ou en d'autres termes, lors de l'accès à un deadline_timer avec expires_from_now()
il va appeler le gestionnaire immédiatement et de ne pas appeler le gestionnaire quand il expire.
Veuillez considérez le code suivant et de sortie correspondant:
#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 avant que la minuterie de construction
20120412 22:41:45689514 avant startTimer()
20120412 22:41:45689619 IsRunning: 1
20120412 22:41:45689693 Handler1: Timer 1 a été annulé ou relancée.
20120412 22:41:46689792 IsRunning: 1
20120412 22:41:47689994 IsRunning: 1
20120412 22:41:48690179 IsRunning: 1
20120412 22:41:49690375 IsRunning: 1
20120412 22:41:50690530 IsRunning: 1
20120412 22:41:51690712 IsRunning: 1
20120412 22:41:52690884 IsRunning: 1
20120412 22:41:53691069 IsRunning: 1
20120412 22:41:54691236 IsRunning: 0
20120412 22:41:55691428 IsRunning: 0
20120412 22:41:56691614 IsRunning: 0
20120412 22:41:57691810 IsRunning: 0
20120412 22:41:58692001 IsRunning: 0
20120412 22:41:59692193 IsRunning: 0
20120412 22:42:00692364 IsRunning: 0
20120412 22:42:01692542 IsRunning: 0
20120412 22:42:02692706 IsRunning: 0
20120412 22:42:03692886 IsRunning: 0
20120412 22:42:04693071 IsRunning: 0
20120412 22:42:05693267 IsRunning: 0
20120412 22:42:06693465 IsRunning: 0
Je vais garder la question ouverte pour l'instant, peut-être quelqu'un peut confirmer mes conclusions.
+1 pour la tête
OriginalL'auteur Michael Hilbert | 2012-04-12
Vous devez vous connecter pour publier un commentaire.
cette hypothèse est incorrecte. Lorsque vous créez votre
deadline_timervous ai dit qu'il expire immédiatement. Ensuite, lorsque vous démarrez votre
io_servicevous invoquer ultérieurement
qui, comme la documentation décrit clairement, cela permettra d'annuler le solde des gestionnaires, emphase ajoutée est la mienne
Pour résoudre ce problème, modifiez votre
Mytimer::startTimer()méthode comme suitqui résultats dans le comportement attendu
Votre sortie s'ouvre une autre question. Comment puis-je concevoir un IsRunning() fonction membre qui ne renvoie pas 0 alors que la minuterie est toujours en cours d'exécution. Une chose qui me vient à l'esprit est à l'aide d'un booléen indicateur privé dans le gestionnaire qui est définie sur false dans le membre de la fonction de gestionnaire. La modification de la total_seconds à total_nanoseconds peut-être une autre option.
il n'est pas évident pour moi ce que vous espérez accomplir cette démarche. Un
deadline_timerexpirera après le moment donné, ou être annulées. Dans ce cas, la solution est de vérifier l'erreur donnée à l'achèvement de gestionnaire.comme vous pouvez le voir à partir de votre sortie ci-dessus, le IsRunning membre d'une fonction retourne false avant la deadline_timer arrive à expiration. Donc, pour moi, cette case n'est toujours pas correcte. Je pense qu'une approche possible est d'avoir un indicateur local, voir ma réponse ci-dessous.
OriginalL'auteur Sam Miller
Le code suivant maintenant la bonne deadline_timer d'initialisation,
et a une private bool drapeau, qui permet de déterminer,
si la minuterie est en cours d'exécution. Il dispose également d'un membre local de gestionnaire.
OriginalL'auteur Michael Hilbert