EventLoopServer.h

// -------------------------------------------------------------------------
#ifndef EventLoopServer_H_
#define EventLoopServer_H_
// -------------------------------------------------------------------------
#include <ev++.h>
#include <atomic>
#include <thread>
// -------------------------------------------------------------------------
namespace uniset
{
class EventLoopServer
{
    public:

        EventLoopServer();
        virtual ~EventLoopServer();

        bool evIsActive() const noexcept;

    protected:
        // действия при завершении
        // завершение своих ev::xxx.stop()
        virtual void evfinish() {}

        // подготовка перед запуском loop
        // запусу своих ev::xxx.start()
        virtual void evprepare() {}

        // Управление потоком событий
        void evrun( bool thread = true );
        void evstop();

        ev::dynamic_loop loop;

    private:

        void onStop() noexcept;
        void defaultLoop() noexcept;

        std::atomic_bool cancelled = { false };
        std::atomic_bool isrunning = { false };

        ev::async evterm;
        std::shared_ptr<std::thread> thr;
};
// -------------------------------------------------------------------------
} // end of uniset namespace
// -------------------------------------------------------------------------
#endif // EventLoopServer_H_
// -------------------------------------------------------------------------