#include <acsncBlockingQueue.h>
Public Member Functions | |
blocking_queue () | |
~blocking_queue () | |
void | push (event_info< T > &data) |
event_info< T > | pop () |
unsigned int | size () |
void | unblock () |
Private Attributes | |
std::queue< event_info< T > > | buffer |
pthread_mutex_t | mutex |
pthread_cond_t | cond |
nc::blocking_queue< T >::blocking_queue | ( | ) |
nc::blocking_queue< T >::~blocking_queue | ( | ) |
event_info<T> nc::blocking_queue< T >::pop | ( | ) |
interrupted_blocking_queue | if the queue was interrupted |
void nc::blocking_queue< T >::push | ( | event_info< T > & | data | ) |
unsigned int nc::blocking_queue< T >::size | ( | ) |
void nc::blocking_queue< T >::unblock | ( | ) |
std::queue<event_info<T> > nc::blocking_queue< T >::buffer [private] |
pthread_cond_t nc::blocking_queue< T >::cond [private] |
pthread_mutex_t nc::blocking_queue< T >::mutex [private] |