PTLib
Version 2.10.4
|
#include <threadpool.h>
Public Member Functions | |
QueuedWorkerThread (PThreadPool< Work_T > &pool, PThread::Priority priority=PThread::NormalPriority) | |
void | AddWork (Work_T *work) |
void | RemoveWork (Work_T *) |
unsigned | GetWorkSize () const |
void | Main () |
void | Shutdown () |
Protected Types | |
typedef std::queue< Work_T * > | Queue |
Protected Attributes | |
Queue | m_queue |
PMutex | m_mutex |
PSemaphore | m_available |
typedef std::queue<Work_T *> PQueuedThreadPool< Work_T >::QueuedWorkerThread::Queue [protected] |
PQueuedThreadPool< Work_T >::QueuedWorkerThread::QueuedWorkerThread | ( | PThreadPool< Work_T > & | pool, |
PThread::Priority | priority = PThread::NormalPriority |
||
) | [inline] |
void PQueuedThreadPool< Work_T >::QueuedWorkerThread::AddWork | ( | Work_T * | work | ) | [inline, virtual] |
unsigned PQueuedThreadPool< Work_T >::QueuedWorkerThread::GetWorkSize | ( | ) | const [inline] |
void PQueuedThreadPool< Work_T >::QueuedWorkerThread::Main | ( | ) | [inline, virtual] |
void PQueuedThreadPool< Work_T >::QueuedWorkerThread::RemoveWork | ( | Work_T * | ) | [inline, virtual] |
void PQueuedThreadPool< Work_T >::QueuedWorkerThread::Shutdown | ( | ) | [inline] |
PSemaphore PQueuedThreadPool< Work_T >::QueuedWorkerThread::m_available [protected] |
PMutex PQueuedThreadPool< Work_T >::QueuedWorkerThread::m_mutex [protected] |
Queue PQueuedThreadPool< Work_T >::QueuedWorkerThread::m_queue [protected] |