#include <concurrency.h>
Definition at line 194 of file concurrency.h.
| dispatcher::dispatcher |
( |
unsigned int |
cap, |
|
|
std::function< void(action)> |
on_drop_callback = nullptr |
|
) |
| |
|
inline |
| dispatcher::~dispatcher |
( |
| ) |
|
|
inline |
| bool dispatcher::empty |
( |
| ) |
|
|
inline |
| bool dispatcher::flush |
( |
| ) |
|
|
inline |
TODO: use _queue to flush, and implement properly
Definition at line 328 of file concurrency.h.
template<class T >
| void dispatcher::invoke |
( |
T |
item, |
|
|
bool |
is_blocking = false |
|
) |
| |
|
inline |
template<class T >
| void dispatcher::invoke_and_wait |
( |
T |
item, |
|
|
std::function< bool()> |
exit_condition, |
|
|
bool |
is_blocking = false |
|
) |
| |
|
inline |
| void dispatcher::start |
( |
| ) |
|
|
inline |
| void dispatcher::stop |
( |
| ) |
|
|
inline |
| std::condition_variable dispatcher::_blocking_invoke_cv |
|
private |
| std::mutex dispatcher::_blocking_invoke_mutex |
|
private |
| std::atomic<bool> dispatcher::_is_alive |
|
private |
| std::thread dispatcher::_thread |
|
private |
| std::atomic<bool> dispatcher::_was_flushed |
|
private |
| std::condition_variable dispatcher::_was_flushed_cv |
|
private |
| std::mutex dispatcher::_was_flushed_mutex |
|
private |
| std::atomic<bool> dispatcher::_was_stopped |
|
private |
| std::condition_variable dispatcher::_was_stopped_cv |
|
private |
| std::mutex dispatcher::_was_stopped_mutex |
|
private |
The documentation for this class was generated from the following file: