X-Git-Url: http://git.tdb.fi/?a=blobdiff_plain;f=source%2Ftime%2Ftimer.h;h=a0dabcdbd7b7cc8e08d553ba7c3e8ea46797762c;hb=5b0c36c9c6c9c30f1eb42186fed7acc7e99faf3e;hp=cfa00bb0d1511f42f09591b04dbc5527ee8deb91;hpb=3d1b0b44b2d75ed7d97b3588eefe61a9b511365c;p=libs%2Fcore.git diff --git a/source/time/timer.h b/source/time/timer.h index cfa00bb..a0dabcd 100644 --- a/source/time/timer.h +++ b/source/time/timer.h @@ -1,13 +1,14 @@ -/* +/* $Id$ + This file is part of libmspcore -Copyright © 2006 Mikko Rasa, Mikkosoft Productions +Copyright © 2006, 2009 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" @@ -41,18 +42,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; - std::priority_queue, fSlotCompare> slots; + SlotProxy(Slot *); + bool operator<(const SlotProxy &) const; + }; + + std::vector slots; Semaphore sem; Mutex mutex; public: - Timer(); ~Timer(); /** @@ -67,6 +72,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. @@ -75,8 +85,8 @@ public: won't return until a timer is added from another thread. */ void tick(bool block=true); -private: - static bool slot_compare(Slot *, Slot *); + + TimeStamp get_next_timeout() const; }; } // namespace Time