cThreadMgr.h

Go to the documentation of this file.

//
//
#ifndef _INC_cThreadMgr_H
#define _INC_cThreadMgr_H
#ifndef NO_PRAGMA_ONCE
#pragma once
#endif
 
#include "cThread.h"
#include "GrayCore/include/cArraySortRef.h"
 
namespace GrayLib
{
        MIDL_INTERFACE("0C3E2E71-B93C-11d2-AAD0-006007654038") IThreadCloseHandler
        {
                IGNORE_WARN_INTERFACE(IThreadCloseHandler);
                virtual void OnThreadClose(THREADID_t nThreadID) = 0;
        };
 
        class GRAYLIB_LINK cThreadMgr
        : public cSingleton<cThreadMgr>
        {
 
                friend class cSingleton<cThreadMgr>;
                friend class cThread;
                CHEAPOBJECT_IMPL;
 
        protected:
                mutable cThreadLockFast m_LockThreads;  
                cArraySortHash<cThread, THREADID_t> m_aThreads; 
                cArrayPtr<IThreadCloseHandler> m_aThreadCloseHandlers;  
 
        private:
                bool AddThread(cThread* pThread);
                bool RemoveThreadId(THREADID_t nThreadId);
                bool RemoveThread(cThread* pThread);
                void ClearTerminatedThreadId(THREADID_t nThreadId);
 
        protected:
                cThreadMgr();
                ~cThreadMgr();
 
        public:
                cThreadLockFast& ref_LockThreads() noexcept
                {
                        return m_LockThreads;
                }
 
                cThreadPtr GetThreadForId(THREADID_t nThreadID) const noexcept;
                bool IsValidThreadId(THREADID_t nThreadID) noexcept // static
                {
                        if (nThreadID == cThreadId::k_NULL)
                                return false;
                        cThreadPtr pThread = GetThreadForId(nThreadID);
                        if (pThread == nullptr)
                        {
                                // Not one of my threads!
                                return false;
                        }
                        return true;    // is this a real valid existing thread id ?
                }
 
                cThread* GetCurrentThread() const noexcept;
                HRESULT CheckAllThreads();      
 
                void Register(IThreadCloseHandler* pLocal);
                void UnRegister(IThreadCloseHandler* pLocal);
        };
};
 
#endif  // _INC_cThreadMgr_H