#include <concurrency.h>
|
| dispatcher (unsigned int queue_capacity, std::function< void(action) > on_drop_callback=nullptr) |
|
| ~dispatcher () |
|
bool | empty () const |
|
template<class T > |
void | invoke (T item, bool is_blocking=false) |
|
template<class T > |
void | invoke_and_wait (T item, std::function< bool()> exit_condition, bool is_blocking=false) |
|
void | stop () |
|
void | start () |
|
bool | flush (std::chrono::steady_clock::duration timeout=std::chrono::seconds(10)) |
|
◆ action
◆ dispatcher()
dispatcher::dispatcher |
( |
unsigned int |
queue_capacity, |
|
|
std::function< void(action) > |
on_drop_callback = nullptr |
|
) |
| |
◆ ~dispatcher()
dispatcher::~dispatcher |
( |
| ) |
|
◆ empty()
bool dispatcher::empty |
( |
| ) |
const |
|
inline |
◆ flush()
bool dispatcher::flush |
( |
std::chrono::steady_clock::duration |
timeout = std::chrono::seconds(10) | ) |
|
◆ invoke()
template<class T >
void dispatcher::invoke |
( |
T |
item, |
|
|
bool |
is_blocking = false |
|
) |
| |
|
inline |
◆ invoke_and_wait()
template<class T >
void dispatcher::invoke_and_wait |
( |
T |
item, |
|
|
std::function< bool()> |
exit_condition, |
|
|
bool |
is_blocking = false |
|
) |
| |
|
inline |
◆ start()
void dispatcher::start |
( |
| ) |
|
◆ stop()
void dispatcher::stop |
( |
| ) |
|
The documentation for this class was generated from the following file:
- /builddir/build/BUILD/librealsense-2.53.1/include/librealsense2/utilities/concurrency/concurrency.h