X-Git-Url: http://git.tdb.fi/?a=blobdiff_plain;f=source%2Ftime%2Ftimer.h;h=7cb5c764d59979e0316e2e365444940ad8e4d786;hb=HEAD;hp=90d870ca9a3afbd44b155f5ccfb5b85747c02442;hpb=aad3371b3d1831dd0525a51e40f637f00be6ff87;p=libs%2Fcore.git diff --git a/source/time/timer.h b/source/time/timer.h index 90d870c..7cb5c76 100644 --- a/source/time/timer.h +++ b/source/time/timer.h @@ -3,7 +3,9 @@ #include #include +#include #include +#include #include #include "timedelta.h" #include "timestamp.h" @@ -18,7 +20,7 @@ of the returned slot. This class is thread-safe, to allow running timers in a separate thread. */ -class Timer +class MSPCORE_API Timer: private NonCopyable { public: class Slot @@ -42,14 +44,13 @@ private: { Slot *slot; - SlotProxy(Slot *); bool operator<(const SlotProxy &) const; }; std::vector slots; Semaphore sem; Mutex mutex; - bool blocking; + bool blocking = false; public: Timer(); @@ -66,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; };