#include <BlockingQueue.h>
Public Member Functions | |
T | pop () |
Block until there is a value to pop. | |
bool | tryPop (T &outValue) |
Non-blocking pop. | |
T | tryPop (const T &valueIfEmpty=T()) |
Non-blocking pop. | |
void | push (const T &t) |
Push a value onto the queue. | |
void | close () |
Close the queue. | |
void | open () |
Open a closed queue. | |
bool | isClosed () const |
bool | empty () const |
size_t | size () const |
bool qpid::sys::BlockingQueue< T >::tryPop | ( | T & | outValue | ) | [inline] |
Non-blocking pop.
If there is a value set outValue and return true, else return false;
Referenced by qpid::sys::BlockingQueue< boost::shared_ptr< FrameSet > >::tryPop().
T qpid::sys::BlockingQueue< T >::tryPop | ( | const T & | valueIfEmpty = T() |
) | [inline] |
Non-blocking pop.
If there is a value return it, else return valueIfEmpty.
void qpid::sys::BlockingQueue< T >::close | ( | ) | [inline] |
Close the queue.
Throws ClosedException in threads waiting in pop(). Blocks till all waiting threads have been notified.
void qpid::sys::BlockingQueue< T >::open | ( | ) | [inline] |
Open a closed queue.