RSC  0.17.1
rsc::threading::OrderedQueueDispatcherPool< M, R >::Receiver Class Reference

Represents on registered receiver of the pool. More...

Collaboration diagram for rsc::threading::OrderedQueueDispatcherPool< M, R >::Receiver:
Collaboration graph

Public Member Functions

 Receiver (boost::shared_ptr< R > receiver)
 

Public Attributes

boost::shared_ptr< R > receiver
 
SynchronizedQueue< M > queue
 
boost::condition processingCondition
 
volatile bool processing
 Indicates whether a job for this worker is currently being processed and this receiver hence cannot be addressed by another thread even though there may be more messages to process. More...
 

Detailed Description

template<class M, class R>
class rsc::threading::OrderedQueueDispatcherPool< M, R >::Receiver

Represents on registered receiver of the pool.

Author
jwienke

Definition at line 195 of file OrderedQueueDispatcherPool.h.

Constructor & Destructor Documentation

template<class M , class R >
rsc::threading::OrderedQueueDispatcherPool< M, R >::Receiver::Receiver ( boost::shared_ptr< R >  receiver)
inline

Definition at line 198 of file OrderedQueueDispatcherPool.h.

Member Data Documentation

template<class M , class R >
volatile bool rsc::threading::OrderedQueueDispatcherPool< M, R >::Receiver::processing

Indicates whether a job for this worker is currently being processed and this receiver hence cannot be addressed by another thread even though there may be more messages to process.

All changes to this flag are already locked by the global recieversMutex.

Definition at line 217 of file OrderedQueueDispatcherPool.h.

template<class M , class R >
boost::condition rsc::threading::OrderedQueueDispatcherPool< M, R >::Receiver::processingCondition

Definition at line 207 of file OrderedQueueDispatcherPool.h.

template<class M , class R >
SynchronizedQueue<M> rsc::threading::OrderedQueueDispatcherPool< M, R >::Receiver::queue

Definition at line 205 of file OrderedQueueDispatcherPool.h.

template<class M , class R >
boost::shared_ptr<R> rsc::threading::OrderedQueueDispatcherPool< M, R >::Receiver::receiver

Definition at line 202 of file OrderedQueueDispatcherPool.h.


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