21 #ifndef INCLUDE_OLA_THREAD_EXECUTORTHREAD_H_ 22 #define INCLUDE_OLA_THREAD_EXECUTORTHREAD_H_ 25 #include <ola/io/SelectServer.h> 26 #include <ola/thread/Thread.h> 27 #include <ola/thread/ConsumerThread.h> 62 m_thread(&m_callback_queue, &m_shutdown, &m_mutex, &m_condition_var,
101 std::queue<ola::BaseCallback0<void>*> m_callback_queue;
114 #endif // INCLUDE_OLA_THREAD_EXECUTORTHREAD_H_ Enables callbacks to be executed in a separate thread.
Definition: ExecutorThread.h:54
void Execute(ola::BaseCallback0< void > *callback)
Execute the supplied callback at some point in the future.
Definition: ExecutorThread.cpp:46
Defer execution of a callback.
Definition: ExecutorInterface.h:35
ExecutorThread(const ola::thread::Thread::Options &options)
Create a new ExecutorThread.
Definition: ExecutorThread.h:60
Definition: ConsumerThread.h:36
Thread options.
Definition: Thread.h:60
bool Stop()
Stop this Executor thread.
Definition: ExecutorThread.cpp:64
The namespace containing all OLA symbols.
Definition: Credentials.cpp:44
void DrainCallbacks()
Block until all pending callbacks have been processed.
Definition: ExecutorThread.cpp:54
bool Start()
Start the ExecutorThread.
Definition: ExecutorThread.cpp:60