Function tutorial_cluster

tutorial/T02-Cluster.cpp:14–46

using namespace CGraph;

void tutorial_cluster() {
    CStatus status;
    GPipelinePtr pipeline = GPipelineFactory::create();
    GElementPtr a, b_cluster, c, d = nullptr;

    b_cluster = pipeline->createGGroup<GCluster>({
         pipeline->createGNode<MyNode1>(GNodeInfo("nodeB1", 1)),    // 创建名为nodeB1的node信息，并将其放入b_cluster中
         pipeline->createGNode<MyNode1>(GNodeInfo("nodeB2", 3)),    // 创建名为nodeB2且自循环3次的node信息，并将其放入b_cluster中
         pipeline->createGNode<MyNode2>(GNodeInfo("nodeB3", 1))
    });    // 创建cluster信息，包含了三个node信息

    /* 正式使用时，请对所有返回值进行判定 */
    status = pipeline->registerGElement<MyNode1>(&a, {}, "nodeA", 1);    // 将名为nodeA的node信息，注册入pipeline中
    status += pipeline->registerGElement<GCluster>(&b_cluster, {a}, "clusterB", 2);    // 将名为clusterB，依赖a执行且自循环2次的cluster信息，注册入pipeline中
    status += pipeline->registerGElement<MyNode1>(&c, {a}, "nodeC", 1);
    status += pipeline->registerGElement<MyNode2>(&d, {b_cluster, c}, "nodeD", 2);
    if (!status.isOK()) {
        return;
    }

    /**
     * 如果想查看当前 pipeline 的流图结构信息，
     * 请调用 dump()方法，并且将输出的内容(不包含node内部的打印信息)，
     * 复制到 https://dreampuf.github.io/GraphvizOnline/ 中查看效果
     */
    // pipeline->dump();

    /* process函数，相当于 init(),run()*n,destroy()函数，同时调用 */
    status = pipeline->process();
    CGRAPH_ECHO("pipeline process status is : [%d]", status.getCode());

    GPipelineFactory::clear();    // clear表示清空所有的pipeline信息
}


int main () {