|
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 |
1.8.1.2