X-Git-Url: http://git.tdb.fi/?a=blobdiff_plain;f=source%2Ftime%2Ftimer.h;h=b080f82f8f3d3713e50dca5b995739f30143e81d;hb=fc1475d88018934a61df890c192a404a105308fd;hp=cfa00bb0d1511f42f09591b04dbc5527ee8deb91;hpb=3d1b0b44b2d75ed7d97b3588eefe61a9b511365c;p=libs%2Fcore.git diff --git a/source/time/timer.h b/source/time/timer.h index cfa00bb..b080f82 100644 --- a/source/time/timer.h +++ b/source/time/timer.h @@ -1,16 +1,10 @@ -/* -This file is part of libmspcore -Copyright © 2006 Mikko Rasa, Mikkosoft Productions -Distributed under the LGPL -*/ - #ifndef MSP_TIME_TIMER_H_ #define MSP_TIME_TIMER_H_ -#include +#include #include -#include "../core/mutex.h" -#include "../core/semaphore.h" +#include +#include #include "timedelta.h" #include "timestamp.h" @@ -41,18 +35,22 @@ public: Slot(const TimeStamp &); const TimeStamp &get_timeout() const { return timeout; } bool increment(); - bool operator<(const Slot &) const; }; private: - typedef bool (*fSlotCompare)(Slot *, Slot *); + struct SlotProxy + { + Slot *slot; + + SlotProxy(Slot *); + bool operator<(const SlotProxy &) const; + }; - std::priority_queue, fSlotCompare> slots; + std::vector slots; Semaphore sem; Mutex mutex; public: - Timer(); ~Timer(); /** @@ -67,6 +65,11 @@ public: */ Slot &add(const TimeStamp &); + /** + 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. @@ -74,9 +77,9 @@ public: 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); -private: - static bool slot_compare(Slot *, Slot *); + void tick(bool block = true); + + TimeStamp get_next_timeout() const; }; } // namespace Time