![]() |
A thread safe monitored queue. More...
#include <Queue.h>
Public Member Functions | |
void | push (const T &value) |
bool | pop (T &value) |
int | size () |
void | wait () |
void | signal () |
Private Attributes | |
Event | m_event |
Mutex | m_mutex |
std::queue< T > | m_queue |
A thread safe monitored queue.
Definition at line 33 of file Queue.h.
bool FIX::Queue< T >::pop | ( | T & | value | ) | [inline] |
Definition at line 43 of file Queue.h.
References FIX::Queue< T >::m_mutex, and FIX::Queue< T >::m_queue.
Referenced by FIX::SocketMonitor::block().
void FIX::Queue< T >::push | ( | const T & | value | ) | [inline] |
Definition at line 36 of file Queue.h.
References FIX::Queue< T >::m_mutex, FIX::Queue< T >::m_queue, and FIX::Queue< T >::signal().
Referenced by FIX::SocketMonitor::drop().
void FIX::Queue< T >::signal | ( | ) | [inline] |
Definition at line 63 of file Queue.h.
References FIX::Queue< T >::m_event, and FIX::Event::signal().
Referenced by FIX::Queue< T >::push().
00064 { 00065 m_event.signal(); 00066 }
int FIX::Queue< T >::size | ( | ) | [inline] |
Definition at line 52 of file Queue.h.
References FIX::Queue< T >::m_mutex, and FIX::Queue< T >::m_queue.
Referenced by FIX::SocketMonitor::block(), FIX::SocketConnection::processQueue(), FIX::SocketConnection::signal(), and FIX::SocketConnection::unsignal().
void FIX::Queue< T >::wait | ( | ) | [inline] |
Definition at line 58 of file Queue.h.
References FIX::Queue< T >::m_event, and FIX::Event::wait().
00059 { 00060 m_event.wait(); 00061 }
Event FIX::Queue< T >::m_event [private] |
Definition at line 69 of file Queue.h.
Referenced by FIX::Queue< T >::signal(), and FIX::Queue< T >::wait().
Mutex FIX::Queue< T >::m_mutex [private] |
Definition at line 70 of file Queue.h.
Referenced by FIX::Queue< T >::pop(), FIX::Queue< T >::push(), and FIX::Queue< T >::size().
std::queue< T > FIX::Queue< T >::m_queue [private] |
Definition at line 71 of file Queue.h.
Referenced by FIX::Queue< T >::pop(), FIX::Queue< T >::push(), and FIX::Queue< T >::size().