cJobFiber.h

Go to the documentation of this file.

//
//
 
#ifndef _INC_cJobFiber_H
#define _INC_cJobFiber_H
#ifndef NO_PRAGMA_ONCE
#pragma once
#endif
 
#include "cJobThreadSet.h"
#include "cThreadFiber.h"
#include "GrayCore/include/cUnitTestDecl.h"
 
namespace GrayLib
{
        UNITTEST2_PREDEF(cJobFiber);
 
        class GRAYLIB_LINK cJobFiberMgr;
 
        class GRAYLIB_LINK cJobFiber
        : public cThreadFiber
        {
 
                typedef cThreadFiber SUPER_t;
 
        private:
                cJobPtr m_pJob;                 
                cJobFiberMgr* m_pParentSet;     
 
        protected:
                void RemoveCurrentJob();
                virtual bool ThreadTick() override;
                virtual void onThreadExit(THREAD_EXITCODE_t nExitCode) override;
 
        public:
                cJobFiber() noexcept;
                virtual ~cJobFiber();
 
                STDMETHOD_(cString, get_Name)() const override
                {
                        if (m_pJob != nullptr)
                        {
                                return m_pJob->get_Name();
                        }
                        return "JobFiber";      // no current m_pJob running. idle.
                }
                cJobPtr get_Job() const
                {
                        return m_pJob;
                }
 
                HRESULT SleepJob(TIMESYSD_t mSec);
 
                void AssignJob(cJobBase* pJob, cJobFiberMgr* pParentSet)
                {
                        // This thread/fiber is now running a job.
                        ASSERT(pJob != nullptr);
                        ASSERT(pParentSet != nullptr);
                        ASSERT(m_pJob == nullptr);      // was idle.
                        m_pJob = pJob;  // nullptr = not in use.
                        m_pParentSet = pParentSet;
                }
 
                UNITTEST2_PREDEF(cJobFiber);
        };
        typedef cRefPtr<cJobFiber> cJobFiberPtr;
 
        //****************************************************************
 
        class GRAYLIB_LINK cJobFiberMgr : public cJobThreadSet<cJobFiber>
        {
 
                friend class cJobFiber;
        public:
                cJobFiberMgr(int iMaxFibers = 32);
                ~cJobFiberMgr();
 
                HRESULT ScheduleJob(cJobBase* pJob, TIMESYSD_t mSecDelay);
                void OnTickJobs(TIMESYSD_t mSec);
        };
};
 
#endif