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