GRUTinizer
|
#include <ThreadsafeQueue.h>
Public Member Functions | |
ThreadsafeQueue () | |
~ThreadsafeQueue () | |
void | Push (T obj) |
int | Pop (T &output, int millisecond_wait=1000) |
size_t | ItemsPushed () |
size_t | ItemsPopped () |
size_t | Size () |
Private Attributes | |
std::mutex | mutex |
std::queue< T > | queue |
std::condition_variable | can_push |
std::condition_variable | can_pop |
size_t | max_queue_size |
size_t | items_in_queue |
size_t | items_pushed |
size_t | items_popped |
ThreadsafeQueue< T >::ThreadsafeQueue | ( | ) |
ThreadsafeQueue< T >::~ThreadsafeQueue | ( | ) |
size_t ThreadsafeQueue< T >::ItemsPopped | ( | ) |
size_t ThreadsafeQueue< T >::ItemsPushed | ( | ) |
int ThreadsafeQueue< T >::Pop | ( | T & | output, |
int | millisecond_wait = 1000 |
||
) |
void ThreadsafeQueue< T >::Push | ( | T | obj | ) |
size_t ThreadsafeQueue< T >::Size | ( | ) |
|
private |
|
private |
|
private |
|
private |
|
private |
|
private |
|
private |
|
private |