#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.