X-Git-Url: http://git.tdb.fi/?a=blobdiff_plain;f=source%2Ftime%2Ftimer.h;h=91acda9d49281373ade15beb162db9f7789c6f99;hb=122846f0881673770d88eff7d925ecf25c01b62e;hp=7566c3dd03a6a86eef6619c2d4ddd24ddbb373ca;hpb=d16185720fa344263367dbd50c61bfc8183d99a4;p=libs%2Fcore.git diff --git a/source/time/timer.h b/source/time/timer.h index 7566c3d..91acda9 100644 --- a/source/time/timer.h +++ b/source/time/timer.h @@ -4,6 +4,7 @@ #include #include #include +#include #include #include "timedelta.h" #include "timestamp.h" @@ -18,7 +19,7 @@ of the returned slot. This class is thread-safe, to allow running timers in a separate thread. */ -class Timer +class Timer: private NonCopyable { public: class Slot @@ -40,7 +41,7 @@ public: private: struct SlotProxy { - Slot *slot; + Slot *slot = 0; SlotProxy(Slot *); bool operator<(const SlotProxy &) const; @@ -49,8 +50,10 @@ private: std::vector slots; Semaphore sem; Mutex mutex; + bool blocking = false; public: + Timer(); ~Timer(); /** Adds a timer that will be executed periodically as long as the timeout @@ -64,13 +67,18 @@ public: /** Cancels a previously added timer. */ void cancel(Slot &); - /** Checks all timers, executing any that have timed out. If block is true, - waits until one times out. + /** Waits until a timer expires, then executes it. If no timers have been + set, blocks until one is added from another thread. */ + void tick(); - Note: If there are no active timers when a blocking tick is executed, it - won't return until a timer is added from another thread. */ - void tick(bool block = true); + /** Waits until a timer expires but at most the specified amount of time. + If a timer did expire before the timeout, it is executed. */ + void tick(const TimeDelta &); +private: + void do_tick(const TimeDelta &); + +public: TimeStamp get_next_timeout() const; };