Nymph
v1.5.2
Flow-Based Data Processing Framework
|
#include <KTConcurrentQueue.hh>
Classes | |
struct | QueueNotEmpty |
Public Types | |
typedef std::deque< XDataType > | Queue |
typedef boost::unique_lock< boost::mutex > | ScopedLock |
Public Member Functions | |
KTConcurrentQueue () | |
virtual | ~KTConcurrentQueue () |
void | push (XDataType const &data) |
bool | empty () const |
bool | size () const |
bool | try_pop (XDataType &popped_value) |
bool | wait_and_pop (XDataType &popped_value) |
bool | timed_wait_and_pop (XDataType &popped_value) |
void | interrupt () |
unsigned | get_timeout () const |
void | set_timeout (unsigned duration) |
Private Attributes | |
Queue | fQueue |
bool | fInterrupt |
boost::posix_time::time_duration | fTimeout |
boost::mutex | fMutex |
Timeout duration in milliseconds. More... | |
boost::condition_variable | fConditionVar |
Definition at line 30 of file KTConcurrentQueue.hh.
typedef std::deque< XDataType > Queue |
Definition at line 33 of file KTConcurrentQueue.hh.
typedef boost::unique_lock< boost::mutex > ScopedLock |
Definition at line 47 of file KTConcurrentQueue.hh.
|
inline |
Definition at line 50 of file KTConcurrentQueue.hh.
|
inlinevirtual |
Definition at line 59 of file KTConcurrentQueue.hh.
|
inline |
Definition at line 85 of file KTConcurrentQueue.hh.
|
inline |
Definition at line 157 of file KTConcurrentQueue.hh.
|
inline |
Definition at line 150 of file KTConcurrentQueue.hh.
|
inline |
Definition at line 74 of file KTConcurrentQueue.hh.
|
inline |
Definition at line 162 of file KTConcurrentQueue.hh.
|
inline |
Definition at line 91 of file KTConcurrentQueue.hh.
|
inline |
Definition at line 128 of file KTConcurrentQueue.hh.
|
inline |
Definition at line 97 of file KTConcurrentQueue.hh.
|
inline |
Definition at line 111 of file KTConcurrentQueue.hh.
|
private |
Definition at line 71 of file KTConcurrentQueue.hh.
|
private |
Definition at line 66 of file KTConcurrentQueue.hh.
|
mutableprivate |
Timeout duration in milliseconds.
Definition at line 70 of file KTConcurrentQueue.hh.
|
private |
Definition at line 65 of file KTConcurrentQueue.hh.
|
private |
Definition at line 68 of file KTConcurrentQueue.hh.