GPipelinePtr pipeline = GPipelineFactory::create();

GElementPtr a, b, c, d, f, g, h = nullptr;

GCoordinatorPtr<-2> e_coordinator = nullptr; // 申明一个减少2个(-2个)辅助线程的 GCoordinator

UThreadPoolConfig config;

config.default_thread_size_ = 0;

config.secondary_thread_size_ = 4; // 设置刚开始的时候，4个辅助线程执行

pipeline->setUniqueThreadPoolConfig(config);

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

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

status += pipeline->registerGElement<MyNode1>(&c, {}, "nodeC");

status += pipeline->registerGElement<MyNode1>(&d, {}, "nodeD");

/**

status += pipeline->registerGElement<GCoordinator<-2>>(&e_coordinator, {a, b, c, d}, "coordinatorE");

status += pipeline->registerGElement<MyNode1>(&f, {e_coordinator}, "nodeF");

status += pipeline->registerGElement<MyNode2>(&g, {f}, "nodeG");

status += pipeline->registerGElement<MyNode2>(&h, {f}, "nodeH");

pipeline->process();

GPipelineFactory::remove(pipeline);