LoopRunner.h

#pragma once

#include <list>

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

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

namespace BeeeOn {

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

        LoopRunner();
        ~LoopRunner();

        void addRunnable(StoppableRunnable::Ptr runnable);
        void addLoop(StoppableLoop::Ptr loop);
        void setAutoStart(bool enable);

        void setStopParallel(bool parallel);

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

protected:
        class Stopper : public Poco::Runnable, Loggable {
        public:
                Stopper();
                Stopper(StoppableLoop::Ptr loop);

                void run() override;

        private:
                StoppableLoop::Ptr m_loop;
        };

        void stopAll(std::list<Stopper> &list);

        void stopParallel(std::list<Stopper> &list);

private:
        bool m_autoStart;
        bool m_stopParallel;
        Poco::FastMutex m_lock;
        std::list<StoppableLoop::Ptr> m_loops;
        std::list<Stopper> m_started;
};

}