cJobThread.h

Go to the documentation of this file.

//
//
 
#ifndef _INC_cJobThread_H
#define _INC_cJobThread_H
#ifndef NO_PRAGMA_ONCE
#pragma once
#endif
 
#include "cJobThreadSet.h"
 
namespace GrayLib
{
        UNITTEST2_PREDEF(cJobThread);
        class GRAYLIB_LINK cJobThreadMgr;
 
        class GRAYLIB_LINK cJobThread
        : public cThreadNamed<cJobThread>
        {
 
                // TODO
 
                typedef cThreadNamed<cJobThread> SUPER_t;
 
        private:
                cJobPtr m_pJob;                 
                cJobThreadMgr* m_pParentSet;    
 
        protected:
                virtual bool ThreadTick() override;
 
        public:
                cJobThread();
                virtual ~cJobThread();
 
                STDMETHOD_(cString, get_Name)() const
                {
                        if (m_pJob != nullptr)
                        {
                                return m_pJob->get_Name();
                        }
                        return "JobThreadIdle"; // no current job running. idle.
                }
                cJobPtr get_Job() const
                {
                        return m_pJob;
                }
 
                void AssignJob(cJobBase* pJob, cJobThreadMgr* pParentSet)
                {
                        ASSERT(pJob != nullptr);
                        ASSERT(pParentSet != nullptr);
                        ASSERT(m_pJob == nullptr);      // was idle.
                        m_pJob = pJob;  // nullptr = not in use.
                        m_pParentSet = pParentSet;
                }
 
                UNITTEST2_PREDEF(cJobThread);
        };
        typedef cRefPtr<cJobThread> cJobThreadPtr;
 
        class GRAYLIB_LINK cJobThreadMgr : public cJobThreadSet<cJobThread>
        {
 
                // TODO
 
                friend class cJobThread;
        public:
                cJobThreadMgr(int iMaxThreads = 32);
                ~cJobThreadMgr();
 
                HRESULT ScheduleJob(cJobBase* pJob, TIMESYSD_t mSecDelay);
                void OnTickJobs();
        };
};
#endif // _INC_cJobThread_H