EuvWork.hpp

//
// Created by xiong on 2021/4/8.
//
 
#ifndef EMX_EuvWork_HPP
#define EMX_EuvWork_HPP
 
#include "EuvLoop.hpp"
 
namespace Emx {
    class EuvWork {
    public:
        EuvWork()
            : m_loop(nullptr), m_work(nullptr), m_arg(nullptr), m_runCb(nullptr), m_afterCb(nullptr),
              m_isWorking(false) {}
 
 
        using RunWorkCallBack = std::function<void(void *arg)>;
 
        using AfterWorkCallBack = std::function<void(Emx::ErrCodeE e, void *arg)>;
 
 
        ErrCodeE Create(EuvLoop *loop, void *arg = nullptr, RunWorkCallBack runCb = nullptr,
                AfterWorkCallBack afterCb = nullptr, const std::string &threadName = "");
 
        void Destroy();
 
        ErrCodeE Run(void *arg = nullptr, RunWorkCallBack runCb = nullptr, AfterWorkCallBack afterCb = nullptr,
                const std::string &threadName = "");
 
        bool IsWorking() { return m_isWorking; }
 
        static void SetWorkNum(int num);
 
        static int GetWorkNum();
 
    private:
        static void OnDestroy(uv_work_t *req, int status);
 
    private:
        EuvLoop *m_loop;
        uv_work_t *m_work;
        void *m_arg;
        RunWorkCallBack m_runCb;
        AfterWorkCallBack m_afterCb;
        bool m_isWorking;
        bool m_isRunning;
        std::string m_threadName;
        bool m_isShowThreadName; 
    };
 
}// namespace Emx
 
#endif//EMX_EuvWork_HPP