BlockingQueue(size_t max_size=WRITE_QUEUE_SIZE) | megatree::BlockingQueue< T > | [inline] |
dequeue() | megatree::BlockingQueue< T > | [inline] |
dequeue_condition | megatree::BlockingQueue< T > | [private] |
dequeueBatch(size_t batch_size, std::vector< T > &batch) | megatree::BlockingQueue< T > | [inline] |
enqueue(const T &item) | megatree::BlockingQueue< T > | [inline] |
enqueue_condition | megatree::BlockingQueue< T > | [private] |
max_size_ | megatree::BlockingQueue< T > | [private] |
mutex_ | megatree::BlockingQueue< T > | [private] |
queue_ | megatree::BlockingQueue< T > | [private] |
unblockAll() | megatree::BlockingQueue< T > | [inline] |