CThreadPoolManager Class Reference

#include <ThreadPool.h>

Collaboration diagram for CThreadPoolManager:

[legend]

List of all members.

Public Member Functions
CThreadPool *	GetPool (DWORD dwThreads)
void	ReleasePool (CThreadPool *pPool)
void	ReleasePool (CThreadPool **ppPool)
	CThreadPoolManager ()
virtual	~CThreadPoolManager ()
Static Public Member Functions
static CThreadPoolManager &	GetInstance ()

---

Detailed Description

Definition at line 257 of file ThreadPool.h.

---

Constructor & Destructor Documentation

CThreadPoolManager::CThreadPoolManager

(

)

Definition at line 60 of file ThreadPool.cpp.

{
    //Create the CS
    m_pCS=COSManager::CreateCriticalSection();
}

CThreadPoolManager::~CThreadPoolManager

(

)

[virtual]

Definition at line 66 of file ThreadPool.cpp.

{
    //Release the CS
    delete m_pCS;
}

---

Member Function Documentation

CThreadPoolManager & CThreadPoolManager::GetInstance

(

)

[static]

Definition at line 180 of file ThreadPool.cpp.

{
    return m_aInstance;
}

CThreadPool * CThreadPoolManager::GetPool

(

DWORD

dwThreads

)

Definition at line 72 of file ThreadPool.cpp.

{
    //Lock the CS
    CCriticalAutoRelease aRelease(m_pCS);

    //Look for a pool
    PoolMap::iterator aIterator;
    aIterator=m_aData.find(dwThreads);

    //Did we get it?
    if (aIterator==m_aData.end())
    {
        //Exit the CS
        aRelease.Exit();

        //Create a new pool
        return new CThreadPool(dwThreads);
    }
    else
    {
        //Get the pool
        CThreadPool* pPool;
        pPool=aIterator->second;

        //Delete tit
        m_aData.erase(aIterator);

        //Exit the CS
        aRelease.Exit();

        //Clean the pool
        pPool->Clear();

        //Done
        return pPool;
    }
}

void CThreadPoolManager::ReleasePool

(

CThreadPool **

ppPool

)

Definition at line 110 of file ThreadPool.cpp.

{
    //Sanity check
    if (!ppPool ||
        !*ppPool)
        return;

    //Get the var
    CThreadPool* pTmp;
    pTmp=*ppPool;
    *ppPool=NULL;

    //And release
    ReleasePool(pTmp);
}

void CThreadPoolManager::ReleasePool

(

CThreadPool *

pPool

)

Definition at line 126 of file ThreadPool.cpp.

{
    //Sanity check
    if (!pPool)
        return;

    //Clear the jobs
    pPool->Clear();

    //The timeout
    DWORD dwTimeout;
    dwTimeout=pPool->GetTimeout();
    if (!dwTimeout)
        dwTimeout=10000;

    //Wait for the jobs to finish
    DWORD dwTick;
    dwTick=GetTickCount();

    //Start to wait
    while (1)
    {
        //Do we have threads?
        if (!pPool->GetRunningThreads())
            break;

        //Do we need to exit
        if (GetTickCount()-dwTick>=dwTimeout)
            break;

        //Sleep a bit
        Sleep(50);
    }

    //Why did we exit?
    if (pPool->GetRunningThreads())
    {
        //We need to get rid of this pool
        pPool->SetTimeout(0);

        //Delete it
        delete pPool;

        //Done
        return;
    }

    //Lock the CS
    CCriticalAutoRelease aRelease(m_pCS);

    //Insert it
    m_aData.insert(PoolMap::value_type(pPool->GetMaxThreads(),pPool));
}

---

The documentation for this class was generated from the following files:

• ThreadPool.h
• ThreadPool.cpp