StoppableLoop.h

#pragma once

#include <Poco/SharedPtr.h>
#include <Poco/Timespan.h>

#include "util/Loggable.h"
#include "loop/StoppableRunnable.h"

namespace Poco {

class Thread;

}

namespace BeeeOn {

class StoppableLoop {
public:
        typedef Poco::SharedPtr<StoppableLoop> Ptr;

        virtual ~StoppableLoop();

        virtual void start() = 0;

        virtual void stop() = 0;
};

class StoppableLoopAdapter :
        public Loggable,
        public StoppableLoop {
public:
        StoppableLoopAdapter(StoppableRunnable::Ptr runnable);
        ~StoppableLoopAdapter();

        void start() override;
        void stop() override;

        void setStopTimeout(const Poco::Timespan &timeout);

        StoppableRunnable::Ptr runnable() const;

protected:
        void doStop();

private:
        Poco::Timespan m_stopTimeout;
        StoppableRunnable::Ptr m_runnable;
        Poco::Thread *m_thread;
};

}