#include <inline_executor.hpp>
Public Types | |
typedef executors::work | work |
type-erasure to store the works to do More... | |
Public Member Functions | |
bool | try_executing_one () |
Effects: try to execute one task. More... | |
inline_executor () | |
inline_executor is not copyable. More... | |
~inline_executor () | |
Effects: Destroys the inline executor. More... | |
void | close () |
Effects: close the inline_executor for submissions. More... | |
bool | closed () |
Returns: whether the pool is closed for submissions. More... | |
void | submit (void(*closure)()) |
Requires: Closure is a model of Callable(void()) and a model of CopyConstructible/MoveConstructible . More... | |
template<typename Closure > | |
void | submit (BOOST_THREAD_FWD_REF(Closure) closure) |
template<typename Pred > | |
bool | reschedule_until (Pred const &) |
Requires: This must be called from an scheduled task. More... | |
Public Attributes | |
bool | closed_ |
type-erasure to store the works to do
|
inline |
inline_executor is not copyable.
Effects: creates a inline executor that runs closures immediately.
Throws: Nothing.
|
inline |
Effects: Destroys the inline executor.
Synchronization: The completion of all the closures happen before the completion of the inline_executor
destructor.
References close().
|
inline |
Effects: close the inline_executor
for submissions.
The loop will work until there is no more closures to run.
Referenced by ~inline_executor().
|
inline |
|
inline |
Requires: This must be called from an scheduled task.
Effects: reschedule functions until pred()
|
inline |
Requires: Closure
is a model of Callable(void())
and a model of CopyConstructible/MoveConstructible
.
Effects: The specified closure
will be scheduled for execution at some point in the future. If invoked closure throws an exception the inline_executor
will call std::terminate
, as is the case with threads.
Synchronization: completion of closure
on a particular thread happens before destruction of thread's thread local variables.
Throws: sync_queue_is_closed
if the thread pool is closed. Whatever exception that can be throw while storing the closure.
References closed().
|
inline |
References closed().
|
inline |
Effects: try to execute one task.
Returns: whether a task has been executed. Throws: whatever the current task constructor throws or the task() throws.
bool boost::executors::inline_executor::closed_ |
Referenced by closed().