GPipelinePtr pipeline = GPipelineFactory::create();

GElementPtr a, b = nullptr;

GFunctionPtr c_function, d_function = nullptr; // 申明两个 GFunction 类型的变量

/** v1.8.3 版本之后，推荐使用+=的形式，对status赋值 */

CStatus status = pipeline->registerGElement<MyNode1>(&a, {}, "nodeA", 1);

status += pipeline->registerGElement<MyWriteParamNode>(&b, {a}, "nodeB", 1);

status += pipeline->registerGElement<GFunction>(&c_function, {b}, "functionC", 1); // 注册GFunction类型的节点c_function

status += pipeline->registerGElement<GFunction>(&d_function, {c_function}, "functionD", 3);

if (!status.isOK()) {

CGRAPH_ECHO("pipeline register failed for the reason : ", status.getInfo().c_str());

return;

}

int num = 10;

const std::string& info = "Hello, CGraph";

c_function->setFunction(CFunctionType::RUN, [num, info] {

CGRAPH_ECHO("input num i = [%d], info = [%s]", num, info.c_str()); // 传递pipeline外部参数，并在pipeline内部节点执行时使用

return CStatus();

});

/** 通过链式调用的方式，注册多个执行函数 */

d_function->setFunction(CFunctionType::INIT, [d_function] {

CGRAPH_ECHO("[%s] do init function ...", d_function->getName().c_str());

return CStatus();

})->setFunction(CFunctionType::RUN, [d_function, num] {

auto param = d_function->getGParamWithNoEmpty<MyParam>("param1");

param->iCount += num;

CGRAPH_ECHO("[%s] do run function, iCount = [%d], iValue = [%d] ...",

d_function->getName().c_str(), param->iCount, ++param->iValue);

return CStatus();

});

pipeline->process();

GPipelineFactory::remove(pipeline);