cThreadFiber.h

Go to the documentation of this file.

//
//
 
#ifndef _INC_cThreadFiber_H
#define _INC_cThreadFiber_H
#ifndef NO_PRAGMA_ONCE
#pragma once
#endif
 
#include "cThread.h"
#include "cSysEvent.h"
#include "GrayCore/include/cRefPtr.h"
 
namespace GrayLib
{
        UNITTEST2_PREDEF(cThreadFiber);
 
        class GRAYLIB_LINK cThreadFiber : public cThreadNamed<cThreadFiber>
        {
 
                typedef cThreadNamed<cThreadFiber> SUPER_t;
 
        private:
                TIMESYS_t m_timeRun;    
                TIMESYS_t m_timeNext;   
 
                cSysEvent m_CallerReady;        
                cSysEvent m_FiberReady;         
 
        protected:
                static HRESULT GRAYCALL SignalObjectAndWaitX(cSysEvent& Ready1, cSysEvent& Wait1, TIMESYSD_t mSecTimeout);
 
                void ClearTimeRun() noexcept
                {
                        m_timeRun = cTimeSys::k_CLEAR;  // Don't want anymore time after this.
                }
                HRESULT YieldFiber(TIMESYSD_t dwTimeWait = cTimeSys::k_INF);    
                virtual void WakeThread() override;
 
        public:
                cThreadFiber() noexcept;
                virtual ~cThreadFiber();
 
                STDMETHOD_(cString, get_Name)() const override  // What task is this ?
                {
                        return "WorkerFiber";
                }
 
                static cThreadFiber* GRAYCALL GetCurrentFiber();
 
                bool IsFiberRunning() const noexcept
                {
                        return isThreadRunning() && !m_bThreadSleeping && !m_bThreadSuspended ;
                }
 
                // Called by parent.
                // Run this thread fiber and suspend caller.
                HRESULT RunFiber(TIMESYSD_t dwTimeMin = 0, TIMESYSD_t dwTimeWait = 0, TIMESYSD_t dwTimeHardMax = cTimeSys::k_INF);
 
                // Called inside fiber ONLY
                virtual void onThreadExit(THREAD_EXITCODE_t nExitCode) override;
 
                // Called by any
                // Wait to be rescheduled. Same as Tick but with a long suspend. Called by fiber.
                virtual HRESULT SleepThread(TIMESYSD_t dwWaitMillisec, bool bAlertable = false) override;
 
                // Give up my time slice and resume my caller. Called by fiber mostly.
                virtual bool ThreadTick() override;
 
                UNITTEST2_PREDEF(cThreadFiber);
        };
};
#endif