TimedEventManager.h

Go to the documentation of this file.

#ifndef __TIMEDEVENTMANAGER_H
#define __TIMEDEVENTMANAGER_H

#include <boost/timer.hpp>
#include <boost/thread/thread.hpp>
#include <boost/pool/object_pool.hpp>

#include "CodeGenMacros.h"
#include "ObjectPool.h"
#include "ThreadPool.h"
#include "Timer.h"

namespace Support
{
    //sets the amount of sleep timer the checking threading spends
    const boost::xtime::xtime_sec_t TimedEventManagerGranularityInSeconds = (boost::xtime::xtime_sec_t)0.01f;

    class TimedEventManager : ThreadPool
    {
    protected:
        struct TimerTracker
        {
        protected:
            ThreadTaskBase* _task;
            Timer _timer;
            bool _recurring;

        public:
            TimerTracker();
            TimerTracker(double periodInSeconds, ThreadTaskBase* task);

            bool operator==(const TimerTracker& rhs);

            INLINE bool isTimerElapsed()
            {
                return _timer.isTargetTimeElapsed();
            }

            INLINE GET(isRecurring, bool, _recurring)
            INLINE SET(setRecurring, bool, _recurring)

            INLINE void reset()
            {
                _timer.restart();
            }

            INLINE bool execute()
            {
                _task->execute();
                if(_recurring)
                {
                    _timer.restart();
                    return false;
                }
                else
                    return true;
            }
        };

        class TimedTask : public ThreadPoolTaskBase
        {
        public:
            TimerTracker _tracker;
            TimedEventManager* _manager;

            TimedTask();

            virtual void execute();
        };

        friend TimedTask;

        class TimerManager : public ThreadPoolTaskBase
        {
            TimedEventManager* _manager;
            boost::xtime _timerGrain;

        public:
            TimerManager(TimedEventManager* manager);
            virtual void execute();
        };

        friend TimerManager;

        std::list<TimerTracker> _timers;

        ObjectPool<TimedTask> _taskPool;

        mutable boost::mutex _timerMutex;

        void checkTimers();

    public:
        TimedEventManager(size_t threadCount);
        ~TimedEventManager();

        void addTimedEvent(double periodInSeconds, ThreadTaskBase* task, bool recurring = false);
    };
}

#endif