EventLoopServer.h

// -------------------------------------------------------------------------
#ifndef EventLoopServer_H_
#define EventLoopServer_H_
// -------------------------------------------------------------------------
#include <ev++.h>
#include <atomic>
#include <thread>
#include <future>
// -------------------------------------------------------------------------
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() {}
 
            // Управление потоком событий
 
            bool async_evrun( size_t waitRunningTimeout_msec = 60000 );
 
            void evstop(); 
            bool evrun();
 
            ev::dynamic_loop loop;
 
        private:
 
            void onStop() noexcept;
            void defaultLoop() noexcept;
            bool waitDefaultLoopRunning( size_t waitTimeout_msec );
            void onLoopOK( ev::timer& t, int revents ) noexcept;
 
            std::atomic_bool cancelled = { false };
            std::atomic_bool isactive = { false };
            std::timed_mutex run_mutex;
 
            ev::async evterm;
            std::unique_ptr<std::thread> thr;
 
            std::mutex              looprunOK_mutex;
            std::condition_variable looprunOK_event;
            std::atomic_bool isrunning = { false };
            ev::timer evruntimer;
    };
    // -------------------------------------------------------------------------
} // end of uniset namespace
// -------------------------------------------------------------------------
#endif // EventLoopServer_H_
// -------------------------------------------------------------------------