YiThreadManager.h

Go to the documentation of this file.

// © You i Labs Inc. 2000-2017. All rights reserved.
#ifndef _YI_THREAD_MANAGER_H_
#define _YI_THREAD_MANAGER_H_

#include "framework/YiPredef.h"
#include "thread/YiMutex.h"
#include "thread/YiWaitCondition.h"

#include <memory>

class CYIThreadManager
{
public: 
    CYIThreadManager() : m_UniqueId(1)
    {}
    
    ~CYIThreadManager()
    {}


    uint32_t CreateManager(uint32_t count);

    void DeleteManager(uint32_t managerId);

    bool GetThread(uint32_t managerId, uint32_t timeout = 0);

    bool ReleaseThread(uint32_t managerId);

    // Informative Data:
    // On a manager:
    bool IsManagerExist(uint32_t managerId) const;
    bool IsManagerActive(uint32_t managerId) const;
    int32_t GetAvailableThreadCount(uint32_t managerId) const;
    // Overall:
    int32_t GetCreatedManagerCount() const;
    int32_t GetActiveManagerCount() const;

private:
    class ManagerInfo
    {
    public:
        ManagerInfo(uint32_t _id, uint32_t _max) :
            m_uId(_id),
            m_uCnt(_max),
            m_uSize(_max),
            m_bIsDeleted(false)
        {}

        bool   IsThreadAvailable()      // Same meaning with the mThreadAvailable condition
        {
            return (m_uCnt != 0);
        }
        uint32_t m_uId;
        uint32_t m_uCnt;
        uint32_t m_uSize;
        bool   m_bIsDeleted;
        mutable   CYIWaitCondition m_ThreadAvailable;
    };

    uint32_t m_UniqueId;

    std::list<std::shared_ptr<ManagerInfo>> m_Managers;
    mutable CYIMutex       m_ManagersMutex;  // Protect when modifying the list
                                            // mutable so that it can be used in const functions
                                            // and the object is still a const 'logically'
};

#endif // _YI_THREAD_MANAGER_H_