ROOT  6.06/09
Reference Guide
Public Member Functions | Private Types | Private Member Functions | Static Private Member Functions | Private Attributes | List of all members
TThreadPool< aTask, aParam > Class Template Reference

template<class aTask, class aParam>
class TThreadPool< aTask, aParam >

Definition at line 118 of file TThreadPool.h.

Public Member Functions

 TThreadPool (size_t threadsCount, bool needDbg=false)
 
 ~TThreadPool ()
 
void AddThread ()
 
void PushTask (typename TThreadPoolTask< aTask, aParam >::task_t &task, aParam param)
 
void Stop (bool processRemainingJobs=false)
 
void Drain ()
 
size_t TasksCount () const
 
size_t SuccessfulTasks () const
 
size_t IdleThreads () const
 

Private Types

typedef TThreadPoolTask< aTask, aParam > task_t
 
typedef std::queue< task_t * > taskqueue_t
 
typedef std::vector< TThread * > threads_array_t
 

Private Member Functions

void DbgLog (const std::string &msg)
 

Static Private Member Functions

static void * Monitor (void *arg)
 
static void * Executor (void *arg)
 
static void * JoinHelper (void *arg)
 
static bool IsThreadActive (TThread *pThread)
 

Private Attributes

taskqueue_t fTasks
 
TMutex fMutex
 
TCondition * fThreadNeeded
 
TCondition * fThreadAvailable
 
TMutex fMutexAllTasksDone
 
TCondition * fAllTasksDone
 
threads_array_t fThreads
 
TThread * fThreadJoinHelper
 
TThread * fThreadMonitor
 
volatile bool fStopped
 
size_t fSuccessfulTasks
 
size_t fTasksCount
 
size_t fIdleThreads
 
TMutex fDbgOutputMutex
 
bool fSilent
 

Additional Inherited Members

- Protected Member Functions inherited from TNonCopyable
 TNonCopyable ()
 
 ~TNonCopyable ()
 

#include <TThreadPool.h>

+ Inheritance diagram for TThreadPool< aTask, aParam >:
+ Collaboration diagram for TThreadPool< aTask, aParam >:

Member Typedef Documentation

template<class aTask , class aParam >
typedef TThreadPoolTask<aTask, aParam> TThreadPool< aTask, aParam >::task_t
private

Definition at line 120 of file TThreadPool.h.

template<class aTask , class aParam >
typedef std::queue<task_t*> TThreadPool< aTask, aParam >::taskqueue_t
private

Definition at line 121 of file TThreadPool.h.

template<class aTask , class aParam >
typedef std::vector<TThread*> TThreadPool< aTask, aParam >::threads_array_t
private

Definition at line 122 of file TThreadPool.h.

Constructor & Destructor Documentation

template<class aTask , class aParam >
TThreadPool< aTask, aParam >::TThreadPool ( size_t  threadsCount,
bool  needDbg = false 
)
inline

Definition at line 125 of file TThreadPool.h.

template<class aTask , class aParam >
TThreadPool< aTask, aParam >::~TThreadPool ( )
inline

Definition at line 149 of file TThreadPool.h.

Member Function Documentation

template<class aTask , class aParam >
void TThreadPool< aTask, aParam >::AddThread ( )
inline

Definition at line 164 of file TThreadPool.h.

template<class aTask , class aParam >
void TThreadPool< aTask, aParam >::DbgLog ( const std::string &  msg)
inlineprivate

Definition at line 331 of file TThreadPool.h.

Referenced by TThreadPool< aTask, aParam >::Executor(), TThreadPool< aTask, aParam >::Monitor(), TThreadPool< aTask, aParam >::PushTask(), and TThreadPool< aTask, aParam >::Stop().

template<class aTask , class aParam >
void TThreadPool< aTask, aParam >::Drain ( )
inline

Definition at line 214 of file TThreadPool.h.

template<class aTask , class aParam >
static void* TThreadPool< aTask, aParam >::Executor ( void *  arg)
inlinestaticprivate

Definition at line 251 of file TThreadPool.h.

Referenced by TThreadPool< aTask, aParam >::AddThread(), and TThreadPool< aTask, aParam >::TThreadPool().

template<class aTask , class aParam >
size_t TThreadPool< aTask, aParam >::IdleThreads ( ) const
inline

Definition at line 229 of file TThreadPool.h.

Referenced by TThreadPool< aTask, aParam >::Monitor().

template<class aTask , class aParam >
static bool TThreadPool< aTask, aParam >::IsThreadActive ( TThread *  pThread)
inlinestaticprivate

Definition at line 326 of file TThreadPool.h.

template<class aTask , class aParam >
static void* TThreadPool< aTask, aParam >::JoinHelper ( void *  arg)
inlinestaticprivate

Definition at line 316 of file TThreadPool.h.

Referenced by TThreadPool< aTask, aParam >::TThreadPool().

template<class aTask , class aParam >
static void* TThreadPool< aTask, aParam >::Monitor ( void *  arg)
inlinestaticprivate

Definition at line 234 of file TThreadPool.h.

Referenced by TThreadPool< aTask, aParam >::TThreadPool().

template<class aTask , class aParam >
void TThreadPool< aTask, aParam >::PushTask ( typename TThreadPoolTask< aTask, aParam >::task_t &  task,
aParam  param 
)
inline

Definition at line 172 of file TThreadPool.h.

template<class aTask , class aParam >
void TThreadPool< aTask, aParam >::Stop ( bool  processRemainingJobs = false)
inline

Definition at line 187 of file TThreadPool.h.

Referenced by TThreadPool< aTask, aParam >::~TThreadPool().

template<class aTask , class aParam >
size_t TThreadPool< aTask, aParam >::SuccessfulTasks ( ) const
inline

Definition at line 225 of file TThreadPool.h.

template<class aTask , class aParam >
size_t TThreadPool< aTask, aParam >::TasksCount ( ) const
inline

Definition at line 221 of file TThreadPool.h.

Member Data Documentation

template<class aTask , class aParam >
TCondition* TThreadPool< aTask, aParam >::fAllTasksDone
private

Definition at line 344 of file TThreadPool.h.

Referenced by TThreadPool< aTask, aParam >::Drain(), TThreadPool< aTask, aParam >::Executor(), TThreadPool< aTask, aParam >::TThreadPool(), and TThreadPool< aTask, aParam >::~TThreadPool().

template<class aTask , class aParam >
TMutex TThreadPool< aTask, aParam >::fDbgOutputMutex
private

Definition at line 352 of file TThreadPool.h.

Referenced by TThreadPool< aTask, aParam >::DbgLog().

template<class aTask , class aParam >
size_t TThreadPool< aTask, aParam >::fIdleThreads
private

Definition at line 351 of file TThreadPool.h.

Referenced by TThreadPool< aTask, aParam >::AddThread(), TThreadPool< aTask, aParam >::Executor(), and TThreadPool< aTask, aParam >::IdleThreads().

template<class aTask , class aParam >
TMutex TThreadPool< aTask, aParam >::fMutex
private

Definition at line 340 of file TThreadPool.h.

Referenced by TThreadPool< aTask, aParam >::AddThread(), TThreadPool< aTask, aParam >::Executor(), TThreadPool< aTask, aParam >::PushTask(), TThreadPool< aTask, aParam >::Stop(), and TThreadPool< aTask, aParam >::TThreadPool().

template<class aTask , class aParam >
TMutex TThreadPool< aTask, aParam >::fMutexAllTasksDone
private

Definition at line 343 of file TThreadPool.h.

Referenced by TThreadPool< aTask, aParam >::Drain(), TThreadPool< aTask, aParam >::Executor(), and TThreadPool< aTask, aParam >::TThreadPool().

template<class aTask , class aParam >
bool TThreadPool< aTask, aParam >::fSilent
private

Definition at line 353 of file TThreadPool.h.

Referenced by TThreadPool< aTask, aParam >::DbgLog().

template<class aTask , class aParam >
volatile bool TThreadPool< aTask, aParam >::fStopped
private

Definition at line 348 of file TThreadPool.h.

Referenced by TThreadPool< aTask, aParam >::Executor(), TThreadPool< aTask, aParam >::Monitor(), and TThreadPool< aTask, aParam >::Stop().

template<class aTask , class aParam >
size_t TThreadPool< aTask, aParam >::fSuccessfulTasks
private

Definition at line 349 of file TThreadPool.h.

Referenced by TThreadPool< aTask, aParam >::Executor(), and TThreadPool< aTask, aParam >::SuccessfulTasks().

template<class aTask , class aParam >
taskqueue_t TThreadPool< aTask, aParam >::fTasks
private

Definition at line 339 of file TThreadPool.h.

Referenced by TThreadPool< aTask, aParam >::Executor(), TThreadPool< aTask, aParam >::Monitor(), TThreadPool< aTask, aParam >::PushTask(), and TThreadPool< aTask, aParam >::Stop().

template<class aTask , class aParam >
size_t TThreadPool< aTask, aParam >::fTasksCount
private

Definition at line 350 of file TThreadPool.h.

Referenced by TThreadPool< aTask, aParam >::PushTask(), and TThreadPool< aTask, aParam >::TasksCount().

template<class aTask , class aParam >
TCondition* TThreadPool< aTask, aParam >::fThreadAvailable
private

Definition at line 342 of file TThreadPool.h.

Referenced by TThreadPool< aTask, aParam >::Executor(), TThreadPool< aTask, aParam >::Stop(), TThreadPool< aTask, aParam >::TThreadPool(), and TThreadPool< aTask, aParam >::~TThreadPool().

template<class aTask , class aParam >
TThread* TThreadPool< aTask, aParam >::fThreadJoinHelper
private

Definition at line 346 of file TThreadPool.h.

Referenced by TThreadPool< aTask, aParam >::Stop(), TThreadPool< aTask, aParam >::TThreadPool(), and TThreadPool< aTask, aParam >::~TThreadPool().

template<class aTask , class aParam >
TThread* TThreadPool< aTask, aParam >::fThreadMonitor
private

Definition at line 347 of file TThreadPool.h.

Referenced by TThreadPool< aTask, aParam >::TThreadPool().

template<class aTask , class aParam >
TCondition* TThreadPool< aTask, aParam >::fThreadNeeded
private

Definition at line 341 of file TThreadPool.h.

Referenced by TThreadPool< aTask, aParam >::Executor(), TThreadPool< aTask, aParam >::PushTask(), TThreadPool< aTask, aParam >::Stop(), TThreadPool< aTask, aParam >::TThreadPool(), and TThreadPool< aTask, aParam >::~TThreadPool().

template<class aTask , class aParam >
threads_array_t TThreadPool< aTask, aParam >::fThreads
private

Definition at line 345 of file TThreadPool.h.

Referenced by TThreadPool< aTask, aParam >::AddThread(), TThreadPool< aTask, aParam >::Executor(), TThreadPool< aTask, aParam >::JoinHelper(), TThreadPool< aTask, aParam >::TThreadPool(), and TThreadPool< aTask, aParam >::~TThreadPool().

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