Public Member Functions | |
QueueThread (QueueThread *_transferQueue=NULL) | |
virtual | ~QueueThread () |
void | run () |
void | cancel () |
bool | isEmpty () |
void | insert (const SystemEvent &event, uint32_t delay) |
Protected Member Functions | |
virtual void | onItemInserted (const SystemEvent &event)=0 |
virtual void | onNextQueueItem (const SystemEvent &event)=0 |
Protected Attributes | |
QueueThread * | transferQueue |
EventQueue | eventsQueue |
boost::mutex | queueMutex |
Static Private Member Functions | |
static void | threadFunc (QueueThread *obj) |
Private Attributes | |
boost::thread * | queueThread |
boost::condition_variable | itemsAvailable |
volatile bool | running |
Definition at line 162 of file SystemQueue.h.
ariba::utility::SystemQueue::QueueThread::QueueThread | ( | QueueThread * | _transferQueue = NULL |
) |
Definition at line 116 of file SystemQueue.cpp.
ariba::utility::SystemQueue::QueueThread::~QueueThread | ( | ) | [virtual] |
Definition at line 120 of file SystemQueue.cpp.
void ariba::utility::SystemQueue::QueueThread::run | ( | ) |
Definition at line 123 of file SystemQueue.cpp.
References queueThread, running, and threadFunc().
Referenced by ariba::utility::SystemQueue::run().
void ariba::utility::SystemQueue::QueueThread::cancel | ( | ) |
Definition at line 129 of file SystemQueue.cpp.
References eventsQueue, itemsAvailable, queueThread, and running.
Referenced by ariba::utility::SystemQueue::cancel().
bool ariba::utility::SystemQueue::QueueThread::isEmpty | ( | ) |
Definition at line 147 of file SystemQueue.cpp.
References eventsQueue, and queueMutex.
Referenced by ariba::utility::SystemQueue::isEmpty().
void ariba::utility::SystemQueue::QueueThread::insert | ( | const SystemEvent & | event, | |
uint32_t | delay | |||
) |
Definition at line 152 of file SystemQueue.cpp.
References eventsQueue, itemsAvailable, onItemInserted(), and queueMutex.
Referenced by ariba::utility::SystemQueue::QueueThreadDelay::onNextQueueItem(), and ariba::utility::SystemQueue::scheduleEvent().
virtual void ariba::utility::SystemQueue::QueueThread::onItemInserted | ( | const SystemEvent & | event | ) | [protected, pure virtual] |
Implemented in ariba::utility::SystemQueue::QueueThreadDirect, and ariba::utility::SystemQueue::QueueThreadDelay.
Referenced by insert().
virtual void ariba::utility::SystemQueue::QueueThread::onNextQueueItem | ( | const SystemEvent & | event | ) | [protected, pure virtual] |
Implemented in ariba::utility::SystemQueue::QueueThreadDirect, and ariba::utility::SystemQueue::QueueThreadDelay.
Referenced by threadFunc().
void ariba::utility::SystemQueue::QueueThread::threadFunc | ( | QueueThread * | obj | ) | [static, private] |
Definition at line 166 of file SystemQueue.cpp.
References eventsQueue, itemsAvailable, onNextQueueItem(), queueMutex, and running.
Referenced by run().
Definition at line 174 of file SystemQueue.h.
Referenced by ariba::utility::SystemQueue::QueueThreadDelay::onNextQueueItem().
Definition at line 175 of file SystemQueue.h.
Referenced by cancel(), insert(), isEmpty(), ariba::utility::SystemQueue::QueueThreadDelay::onItemInserted(), and threadFunc().
boost::mutex ariba::utility::SystemQueue::QueueThread::queueMutex [protected] |
boost::thread* ariba::utility::SystemQueue::QueueThread::queueThread [private] |
boost::condition_variable ariba::utility::SystemQueue::QueueThread::itemsAvailable [private] |
volatile bool ariba::utility::SystemQueue::QueueThread::running [private] |