|
spdlog
|
Definition at line 22 of file mpmc_blocking_q.h.
#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 |
Definition at line 25 of file mpmc_blocking_q.h.
|
inlineexplicit |
Definition at line 26 of file mpmc_blocking_q.h.
|
inline |
Definition at line 54 of file mpmc_blocking_q.h.
|
inline |
Definition at line 32 of file mpmc_blocking_q.h.
|
inline |
Definition at line 43 of file mpmc_blocking_q.h.
|
inline |
Definition at line 107 of file mpmc_blocking_q.h.
|
inline |
Definition at line 113 of file mpmc_blocking_q.h.
|
private |
Definition at line 122 of file mpmc_blocking_q.h.
|
private |
Definition at line 121 of file mpmc_blocking_q.h.
|
private |
Definition at line 123 of file mpmc_blocking_q.h.
|
private |
Definition at line 120 of file mpmc_blocking_q.h.