cJobThreadSet.h

Go to the documentation of this file.

//
//
 
#ifndef _INC_cJobThreadSet_H
#define _INC_cJobThreadSet_H
#ifndef NO_PRAGMA_ONCE
#pragma once
#endif
 
#include "cJobBase.h"
#include "cThread.h"
 
namespace GrayLib
{
        template < class T >
        class GRAYLIB_LINK cJobThreadPool
        : public cSingleton< cJobThreadPool<T> >
        {
 
                typedef cJobThreadPool<T> POOL_t;
                typedef cSingleton<POOL_t> SUPER_t;
 
                friend class cSingleton< cJobThreadPool<T> >;
                CHEAPOBJECT_IMPL;
 
        private:
                cThreadLockArraySmart<T> m_aFree;
 
        protected:
                cJobThreadPool() 
                : cSingleton<POOL_t>(this, typeid(POOL_t))
                {
                }
                ~cJobThreadPool()
                {
                }
 
        public:
                inline ITERATE_t get_FreeThreadQty() const noexcept
                {
                        return m_aFree.GetSize();
                }
                cRefPtr<T> PopFreeThread()
                {
                        // Get a free thread if i have any.
                        return m_aFree.PopTail();
                }
                ITERATE_t AddFreeThread(T* pThread)
                {
                        ASSERT(pThread != nullptr);
                        ASSERT(pThread->get_Job() == nullptr);
                        ASSERT(!m_aFree.HasArg(pThread));
                        return m_aFree.Add(pThread);    // to tail.
                }
                void ClearFreeThreads()
                {
                        cThreadGuard threadguard(m_aFree.m_Lock);
                        // like RequestStopThreadArray
                        for (int i = 0; i < m_aFree.GetSize(); i++)
                        {
                                m_aFree.GetAtCheck(i)->RequestStopThread(true);
                        }
                        m_aFree.RemoveAll();
                }
        };
 
        template < class T >
        class GRAYLIB_LINK cJobThreadSet
        {
 
        protected:
                const int m_iMinThreads;        
                const int m_iMaxThreads;        
                                                                        
                cArrayRef<T> m_aRunningThreads; 
                
                cJobArray m_WaitingJobs;        
 
        public:
                inline cJobThreadSet(int iMinThreads = 0, int iMaxThreads = 32) noexcept
                        : m_iMinThreads(iMinThreads)
                        , m_iMaxThreads(iMaxThreads)
                {
                }
 
                inline ITERATE_t get_RunningJobQty() const noexcept
                {
                        return m_aRunningThreads.GetSize();
                }
                inline ITERATE_t get_WaitingJobQty() const noexcept
                {
                        return m_WaitingJobs.GetSize();
                }
        };
}
#endif