#include <concurrent_queue.h>
Public Member Functions | |
void | cancel () |
void | clear () |
void | clear_cancel () |
ConcurrentQueue () | |
bool | empty () const |
void | push (Data const &data) |
size_t | size () const |
bool | timed_wait_and_pop (Data &popped_value, long timeout) |
bool | try_pop (Data &popped_value) |
void | wait_and_pop (Data &popped_value) |
Private Attributes | |
bool | canceled_ |
boost::condition_variable | the_condition_variable |
boost::mutex | the_mutex |
std::queue< Data > | the_queue |
Definition at line 11 of file concurrent_queue.h.
serial::utils::ConcurrentQueue< Data >::ConcurrentQueue | ( | ) | [inline] |
Definition at line 19 of file concurrent_queue.h.
void serial::utils::ConcurrentQueue< Data >::cancel | ( | ) | [inline] |
Definition at line 76 of file concurrent_queue.h.
void serial::utils::ConcurrentQueue< Data >::clear | ( | ) | [inline] |
Definition at line 85 of file concurrent_queue.h.
void serial::utils::ConcurrentQueue< Data >::clear_cancel | ( | ) | [inline] |
Definition at line 81 of file concurrent_queue.h.
bool serial::utils::ConcurrentQueue< Data >::empty | ( | ) | const [inline] |
Definition at line 28 of file concurrent_queue.h.
void serial::utils::ConcurrentQueue< Data >::push | ( | Data const & | data | ) | [inline] |
Definition at line 21 of file concurrent_queue.h.
size_t serial::utils::ConcurrentQueue< Data >::size | ( | ) | const [inline] |
Definition at line 72 of file concurrent_queue.h.
bool serial::utils::ConcurrentQueue< Data >::timed_wait_and_pop | ( | Data & | popped_value, |
long | timeout | ||
) | [inline] |
Definition at line 44 of file concurrent_queue.h.
bool serial::utils::ConcurrentQueue< Data >::try_pop | ( | Data & | popped_value | ) | [inline] |
Definition at line 33 of file concurrent_queue.h.
void serial::utils::ConcurrentQueue< Data >::wait_and_pop | ( | Data & | popped_value | ) | [inline] |
Definition at line 60 of file concurrent_queue.h.
bool serial::utils::ConcurrentQueue< Data >::canceled_ [private] |
Definition at line 17 of file concurrent_queue.h.
boost::condition_variable serial::utils::ConcurrentQueue< Data >::the_condition_variable [private] |
Definition at line 16 of file concurrent_queue.h.
boost::mutex serial::utils::ConcurrentQueue< Data >::the_mutex [mutable, private] |
Definition at line 15 of file concurrent_queue.h.
std::queue<Data> serial::utils::ConcurrentQueue< Data >::the_queue [private] |
Definition at line 14 of file concurrent_queue.h.