PQueuedThreadPool< Work_T >::QueuedWorkerThread Class Reference

#include <threadpool.h>

Inheritance diagram for PQueuedThreadPool< Work_T >::QueuedWorkerThread:

Collaboration diagram for PQueuedThreadPool< Work_T >::QueuedWorkerThread:

Classes
struct	QueuedWork

Public Member Functions
	QueuedWorkerThread (PThreadPool< Work_T > &pool, PThread::Priority priority=PThread::NormalPriority, const char *threadName=NULL)
	~QueuedWorkerThread ()
void	AddWork (Work_T *work, const string &group)
void	RemoveWork (Work_T *work)
unsigned	GetWorkSize () const
virtual bool	Work ()
void	Shutdown ()

Protected Attributes
PSyncQueue< QueuedWork >	m_queue
atomic< bool >	m_working

Additional Inherited Members
Protected Member Functions inherited from PThreadPool< Work_T >::WorkerThread
	WorkerThread (PThreadPool &pool, Priority priority=NormalPriority, const char *threadName=NULL)

Constructor & Destructor Documentation

template<class Work_T>

PQueuedThreadPool< Work_T >::QueuedWorkerThread::QueuedWorkerThread ( PThreadPool< Work_T > &  pool, PThread::Priority  priority = PThread::NormalPriority, const char *  threadName = NULL  )

inline

template<class Work_T>

PQueuedThreadPool< Work_T >::QueuedWorkerThread::~QueuedWorkerThread ( )

inline

Member Function Documentation

template<class Work_T>

void PQueuedThreadPool< Work_T >::QueuedWorkerThread::AddWork ( Work_T *  work, const string &  group  )

inlinevirtual

Implements PThreadPool< Work_T >::WorkerThread.

References PQueuedThreadPool< Work_T >::QueuedWorkerThread::m_queue, and PAssertNULL.

template<class Work_T>

unsigned PQueuedThreadPool< Work_T >::QueuedWorkerThread::GetWorkSize ( ) const

inline

References PQueuedThreadPool< Work_T >::QueuedWorkerThread::m_queue, and PQueuedThreadPool< Work_T >::QueuedWorkerThread::m_working.

template<class Work_T>

void PQueuedThreadPool< Work_T >::QueuedWorkerThread::RemoveWork ( Work_T *  work )

inlinevirtual

Implements PThreadPool< Work_T >::WorkerThread.

Referenced by PQueuedThreadPool< Work_T >::QueuedWorkerThread::Work().

template<class Work_T>

void PQueuedThreadPool< Work_T >::QueuedWorkerThread::Shutdown ( )

inline

References PQueuedThreadPool< Work_T >::QueuedWorkerThread::m_queue.

template<class Work_T>

virtual bool PQueuedThreadPool< Work_T >::QueuedWorkerThread::Work ( )

inlinevirtual

References PTime::GetElapsed(), PQueuedThreadPool< Work_T >::QueuedWorkerThread::QueuedWork::m_group, PQueuedThreadPool< Work_T >::QueuedWorkerThread::m_queue, PQueuedThreadPool< Work_T >::QueuedWorkerThread::QueuedWork::m_time, PQueuedThreadPool< Work_T >::QueuedWorkerThread::QueuedWork::m_work, PQueuedThreadPool< Work_T >::m_workerIncreaseLatency, PQueuedThreadPool< Work_T >::QueuedWorkerThread::m_working, PQueuedThreadPool< Work_T >::OnMaxWaitTime(), PThreadPool< Work_T >::RemoveWork(), and PQueuedThreadPool< Work_T >::QueuedWorkerThread::RemoveWork().

Member Data Documentation

template<class Work_T>

PSyncQueue<QueuedWork> PQueuedThreadPool< Work_T >::QueuedWorkerThread::m_queue

protected

Referenced by PQueuedThreadPool< Work_T >::QueuedWorkerThread::AddWork(), PQueuedThreadPool< Work_T >::QueuedWorkerThread::GetWorkSize(), PQueuedThreadPool< Work_T >::QueuedWorkerThread::Shutdown(), and PQueuedThreadPool< Work_T >::QueuedWorkerThread::Work().

template<class Work_T>

atomic<bool> PQueuedThreadPool< Work_T >::QueuedWorkerThread::m_working

protected

Referenced by PQueuedThreadPool< Work_T >::QueuedWorkerThread::GetWorkSize(), and PQueuedThreadPool< Work_T >::QueuedWorkerThread::Work().

---

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

• threadpool.h