Agora
1.2.0
Agora project
|
#include <mpmc_blocking_q.h>
Public Types | |
using | item_type = T |
Public Member Functions | |
mpmc_blocking_queue (size_t max_items) | |
void | enqueue (T &&item) |
void | enqueue_nowait (T &&item) |
bool | dequeue_for (T &popped_item, std::chrono::milliseconds wait_duration) |
size_t | overrun_counter () |
size_t | size () |
Private Attributes | |
std::mutex | queue_mutex_ |
std::condition_variable | push_cv_ |
std::condition_variable | pop_cv_ |
spdlog::details::circular_q< T > | q_ |
using spdlog::details::mpmc_blocking_queue< T >::item_type = T |
|
inlineexplicit |
|
inline |
|
inline |
|
inline |
|
inline |
|
inline |
|
private |
|
private |
|
private |
|
private |