![]() |
Scarab
v3.2.1
Project 8 C++ Utility Library
|
#include <concurrent_queue.hh>
Classes | |
struct | queue_not_empty |
Public Types | |
typedef std::deque< XDataType > | queue |
typedef std::unique_lock< std::mutex > | cq_lock |
Public Member Functions | |
concurrent_queue () | |
virtual | ~concurrent_queue () |
void | push (XDataType const &a_data) |
bool | empty () const |
unsigned | size () const |
bool | try_pop (XDataType &a_popped_value) |
bool | wait_and_pop (XDataType &a_popped_value) |
bool | timed_wait_and_pop (XDataType &a_popped_value) |
void | interrupt () |
unsigned | get_timeout () const |
void | set_timeout (unsigned a_duration) |
Private Attributes | |
queue | f_queue |
bool | f_interrupt |
std::chrono::milliseconds | f_timeout |
std::mutex | f_mutex |
Timeout duration in milliseconds. More... | |
std::condition_variable | f_condition_var |
Definition at line 30 of file concurrent_queue.hh.
typedef std::unique_lock< std::mutex > cq_lock |
Definition at line 47 of file concurrent_queue.hh.
typedef std::deque< XDataType > queue |
Definition at line 33 of file concurrent_queue.hh.
|
inline |
Definition at line 50 of file concurrent_queue.hh.
|
inlinevirtual |
Definition at line 59 of file concurrent_queue.hh.
|
inline |
Definition at line 85 of file concurrent_queue.hh.
|
inline |
Definition at line 157 of file concurrent_queue.hh.
|
inline |
Definition at line 150 of file concurrent_queue.hh.
|
inline |
Definition at line 74 of file concurrent_queue.hh.
|
inline |
Definition at line 162 of file concurrent_queue.hh.
|
inline |
Definition at line 91 of file concurrent_queue.hh.
|
inline |
Definition at line 128 of file concurrent_queue.hh.
|
inline |
Definition at line 97 of file concurrent_queue.hh.
|
inline |
Definition at line 111 of file concurrent_queue.hh.
|
private |
Definition at line 71 of file concurrent_queue.hh.
|
private |
Definition at line 66 of file concurrent_queue.hh.
|
mutableprivate |
Timeout duration in milliseconds.
Definition at line 70 of file concurrent_queue.hh.
|
private |
Definition at line 65 of file concurrent_queue.hh.
|
private |
Definition at line 68 of file concurrent_queue.hh.