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();

/* process函数，相当于 init(),run()*n,destroy()函数，同时调用 */

status = pipeline->process();

CGRAPH_ECHO("pipeline process status is : [%d]", status.getCode());

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