WaitCondition.h

#pragma once

#include <Poco/AtomicCounter.h>
#include <Poco/Condition.h>
#include <Poco/Mutex.h>
#include <Poco/Timespan.h>

namespace BeeeOn {

class WaitCondition {
public:
        WaitCondition(bool repeat = true);
        ~WaitCondition();

        class Broadcaster {
        public:
                Broadcaster(WaitCondition &condition);

                ~Broadcaster();

                void broadcast();

        private:
                bool m_broadcasted;
                WaitCondition &m_condition;
        };

        void wait(const Poco::Timespan &timeout = -1);

        bool tryWait(const Poco::Timespan &timeout = -1);

        void broadcast();

protected:
        long toMilliseconds(const Poco::Timespan &timeout) const;

        bool doWait(long ms);

private:
        Poco::FastMutex m_lock;
        Poco::Condition m_condition;
        bool m_canRepeat;
        Poco::AtomicCounter m_broadcasted;
};

}