#include <kanzi/scheduler/pipeline.hpp>
Public Member Functions | |
| Pipeline () | |
| Constructor. More... | |
| ~Pipeline () | |
| Destructor. More... | |
| void | startAsync () |
| void | startSync () |
| void | stopAsync () |
| void | stopSync () |
| void | joinAsync () |
| void | joinSync () |
| void | appendTask (Task task) |
| size_t | taskCount () const |
| Task | getTask (size_t index) const |
| bool | isRunning () const |
| void | appendInitTask (Task task) |
| void | appendDeinitTask (Task task) |
| void | runInit () |
| void | runDeinit () |
Protected Attributes | |
| bool | m_running |
| State flag. More... | |
| TaskContainer | m_initTasks |
| Initialization task container. More... | |
| TaskContainer | m_loopTasks |
| Actual task container. More... | |
| TaskContainer | m_deinitTasks |
| Deinitialization task container. More... | |
| struct KzsThread * | m_thread |
| Thread for asynchronous operation. More... | |
Pipeline class.
Represents container for sequentially executable of tasks.
| kanzi::Pipeline::Pipeline | ( | ) |
Constructor.
| kanzi::Pipeline::~Pipeline | ( | ) |
Destructor.
| void kanzi::Pipeline::startAsync | ( | ) |
| void kanzi::Pipeline::startSync | ( | ) |
| void kanzi::Pipeline::stopAsync | ( | ) |
| void kanzi::Pipeline::stopSync | ( | ) |
| void kanzi::Pipeline::joinAsync | ( | ) |
| void kanzi::Pipeline::joinSync | ( | ) |
| void kanzi::Pipeline::appendTask | ( | Task | task | ) |
| size_t kanzi::Pipeline::taskCount | ( | ) | const |
| Task kanzi::Pipeline::getTask | ( | size_t | index | ) | const |
| bool kanzi::Pipeline::isRunning | ( | ) | const |
| void kanzi::Pipeline::appendInitTask | ( | Task | task | ) |
| void kanzi::Pipeline::appendDeinitTask | ( | Task | task | ) |
| void kanzi::Pipeline::runInit | ( | ) |
| void kanzi::Pipeline::runDeinit | ( | ) |
|
protected |
State flag.
|
protected |
Initialization task container.
|
protected |
Actual task container.
|
protected |
Deinitialization task container.
|
protected |
Thread for asynchronous operation.