ThreadedMessageQueue< T > Class Template Reference
Provides a mechanism for exchanging messages between threads. More...
#include <ThreadedMessageQueue.h>
Detailed Description
template<class T>
class ThreadedMessageQueue< T >
Provides a mechanism for exchanging messages between threads.
Receivers are responsible for message cleanup/deletion.
Definition at line 13 of file ThreadedMessageQueue.h.
Classes | |
| class | ReceiverThread |
| Pulls messages out of the queue and gives them to the specified callback. More... | |
| class | ReceiverThreadBase |
| Holds controller flags for the receiver thread to indicate exit conditions. More... | |
Public Member Functions | |
| ThreadedMessageQueue () | |
| Constructor. | |
| ~ThreadedMessageQueue () | |
| Destructor, calls finishCallback(). | |
| void | send (const T &msg) |
| Adds a message to the queue. | |
| template<class F > | |
| void | for_each (const F &f) |
| Applies the specified predicate to each of the messages (you can modify the queue value itself via pass-by-reference). | |
| template<class F > | |
| void | remove (const F &f) |
| Applies the specified predicate to each of the message, removing those for which the predicate returns true. | |
| size_t | size () const |
| Returns number of messages in msgs. | |
| void | clear () |
| Clears any backlog. | |
| const T & | front () const |
| Returns the next message (does not remove from the queue), blocking until available. | |
| void | pop () |
| Removes the front message, if any. | |
| template<typename F , typename C > | |
| void | spawnCallback (F fn, C &cl) |
| Spawns a thread to trigger a class member callback with each message - only a single receiver is supported, so this replaces any previous receiver. | |
| void | stopCallback () |
| Sends a thread cancellation to the receiver thread to halt processing. | |
| void | finishCallback () |
| Sets a flag to exit the receiver thread at the completion of the current callback. | |
| void | finishQueue () |
| Sets a flag that when the receiver gets to the end of the queue, it will exit. | |
Protected Attributes | |
| Thread::Lock | lock |
| provides mutual exclusion on msgs operations and signal reception | |
| Thread::Condition | signal |
| connects notification of send() in receiver | |
| std::list< T > | msgs |
| unprocessed messages | |
| ReceiverThreadBase * | receiver |
| currently only a single receiver is supported | |
Private Member Functions | |
| ThreadedMessageQueue (const ThreadedMessageQueue &o) | |
| Do not call. | |
| ThreadedMessageQueue & | operator= (const ThreadedMessageQueue &o) |
| Do not call. | |
Constructor & Destructor Documentation
| ThreadedMessageQueue< T >::ThreadedMessageQueue | ( | ) |
Constructor.
Definition at line 16 of file ThreadedMessageQueue.h.
| ThreadedMessageQueue< T >::~ThreadedMessageQueue | ( | ) |
Destructor, calls finishCallback().
Definition at line 19 of file ThreadedMessageQueue.h.
| ThreadedMessageQueue< T >::ThreadedMessageQueue | ( | const ThreadedMessageQueue< T > & | o | ) | [private] |
Do not call.
Member Function Documentation
| void ThreadedMessageQueue< T >::clear | ( | ) |
Clears any backlog.
Definition at line 34 of file ThreadedMessageQueue.h.
| void ThreadedMessageQueue< T >::finishCallback | ( | ) |
Sets a flag to exit the receiver thread at the completion of the current callback.
If no callback is active, cancels the receiver immediately -- doesn't wait for another message first
Definition at line 76 of file ThreadedMessageQueue.h.
Referenced by ThreadedMessageQueue< EventBase * >::~ThreadedMessageQueue().
| void ThreadedMessageQueue< T >::finishQueue | ( | ) |
Sets a flag that when the receiver gets to the end of the queue, it will exit.
If the receiver is already blocking at the end of the queue, stops the thread now
Definition at line 92 of file ThreadedMessageQueue.h.
Applies the specified predicate to each of the messages (you can modify the queue value itself via pass-by-reference).
Definition at line 25 of file ThreadedMessageQueue.h.
Referenced by ThreadedMessageQueue< EventBase * >::for_each().
| const T& ThreadedMessageQueue< T >::front | ( | ) | const |
Returns the next message (does not remove from the queue), blocking until available.
Definition at line 37 of file ThreadedMessageQueue.h.
Referenced by ThreadedMessageQueue< T >::ReceiverThread< F, C >::run().
| ThreadedMessageQueue& ThreadedMessageQueue< T >::operator= | ( | const ThreadedMessageQueue< T > & | o | ) | [private] |
Do not call.
| void ThreadedMessageQueue< T >::pop | ( | ) |
Removes the front message, if any.
Definition at line 45 of file ThreadedMessageQueue.h.
Referenced by ThreadedMessageQueue< T >::ReceiverThread< F, C >::run().
Applies the specified predicate to each of the message, removing those for which the predicate returns true.
Definition at line 28 of file ThreadedMessageQueue.h.
Referenced by EventRouter::requeueEvent().
| void ThreadedMessageQueue< T >::send | ( | const T & | msg | ) |
Adds a message to the queue.
Definition at line 22 of file ThreadedMessageQueue.h.
Referenced by EventRouter::queueEvent().
| size_t ThreadedMessageQueue< T >::size | ( | ) | const |
Returns number of messages in msgs.
Definition at line 31 of file ThreadedMessageQueue.h.
Referenced by ThreadedMessageQueue< T >::ReceiverThread< F, C >::run().
| void ThreadedMessageQueue< T >::spawnCallback | ( | F | fn, | |
| C & | cl | |||
| ) |
Spawns a thread to trigger a class member callback with each message - only a single receiver is supported, so this replaces any previous receiver.
Definition at line 49 of file ThreadedMessageQueue.h.
| void ThreadedMessageQueue< T >::stopCallback | ( | ) |
Sends a thread cancellation to the receiver thread to halt processing.
Definition at line 56 of file ThreadedMessageQueue.h.
Referenced by ThreadedMessageQueue< EventBase * >::spawnCallback().
Member Data Documentation
Thread::Lock ThreadedMessageQueue< T >::lock [mutable, protected] |
provides mutual exclusion on msgs operations and signal reception
Definition at line 107 of file ThreadedMessageQueue.h.
Referenced by ThreadedMessageQueue< EventBase * >::clear(), ThreadedMessageQueue< EventBase * >::finishCallback(), ThreadedMessageQueue< EventBase * >::finishQueue(), ThreadedMessageQueue< EventBase * >::front(), ThreadedMessageQueue< EventBase * >::pop(), ThreadedMessageQueue< EventBase * >::send(), and ThreadedMessageQueue< EventBase * >::stopCallback().
std::list<T> ThreadedMessageQueue< T >::msgs [protected] |
unprocessed messages
Definition at line 109 of file ThreadedMessageQueue.h.
Referenced by ThreadedMessageQueue< EventBase * >::clear(), ThreadedMessageQueue< EventBase * >::finishCallback(), ThreadedMessageQueue< EventBase * >::finishQueue(), ThreadedMessageQueue< EventBase * >::for_each(), ThreadedMessageQueue< EventBase * >::front(), ThreadedMessageQueue< EventBase * >::pop(), ThreadedMessageQueue< EventBase * >::remove(), ThreadedMessageQueue< EventBase * >::send(), and ThreadedMessageQueue< EventBase * >::size().
ReceiverThreadBase* ThreadedMessageQueue< T >::receiver [protected] |
currently only a single receiver is supported
Definition at line 139 of file ThreadedMessageQueue.h.
Referenced by ThreadedMessageQueue< EventBase * >::finishCallback(), ThreadedMessageQueue< EventBase * >::finishQueue(), ThreadedMessageQueue< EventBase * >::spawnCallback(), and ThreadedMessageQueue< EventBase * >::stopCallback().
Thread::Condition ThreadedMessageQueue< T >::signal [protected] |
connects notification of send() in receiver
Definition at line 108 of file ThreadedMessageQueue.h.
Referenced by ThreadedMessageQueue< EventBase * >::front(), and ThreadedMessageQueue< EventBase * >::send().
The documentation for this class was generated from the following file:
