Function tutorial_function

tutorial/T12-Function.cpp:14–50

using namespace CGraph;

void tutorial_function() {
    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);
}


int main() {