ROOT  6.07/01
Reference Guide
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Properties Friends Macros Groups Pages
List of all members | 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 119 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 >:
[legend]

Member Typedef Documentation

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

Definition at line 121 of file TThreadPool.h.

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

Definition at line 122 of file TThreadPool.h.

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

Definition at line 123 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 126 of file TThreadPool.h.

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

Definition at line 150 of file TThreadPool.h.

Member Function Documentation

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

Definition at line 165 of file TThreadPool.h.

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

Definition at line 332 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 215 of file TThreadPool.h.

Referenced by stressThreadPool().

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

Definition at line 252 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 230 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 327 of file TThreadPool.h.

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

Definition at line 317 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 235 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 173 of file TThreadPool.h.

Referenced by stressThreadPool(), and threadPool().

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

Definition at line 188 of file TThreadPool.h.

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

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

Definition at line 226 of file TThreadPool.h.

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

Definition at line 222 of file TThreadPool.h.

Member Data Documentation

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

Definition at line 345 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 353 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 352 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 341 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 344 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 354 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 349 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 350 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 340 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 351 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 343 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 347 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 348 of file TThreadPool.h.

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

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

Definition at line 342 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 346 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().

Collaboration diagram for TThreadPool< aTask, aParam >:
[legend]
The documentation for this class was generated from the following file: