CStatus status;

GElementPtr a, b;

GPipelinePtr pubPipeLine = GPipelineFactory::create();

// 注册用于 发送 的pipeline

status += pubPipeLine->registerGElement<MyNode1>(&a, {}, "myNode1");

status += pubPipeLine->registerGElement<MySendMessageNode>(&b, {a});

pubPipeLine->process(3);

CStatus status;

GElementPtr a, b;

GPipelinePtr subPipeline = GPipelineFactory::create();

// 注册用于 接收 的pipeline

status += subPipeline->registerGElement<MyNode2>(&a, {}, "myNode2");

status += subPipeline->registerGElement<MyRecvMessageNode>(&b, {a});

subPipeline->process(3);

CGRAPH_CREATE_MESSAGE_TOPIC(MyMessageParam, "send-recv", 48) // 创建一个topic，也在算子中实现创建流程

std::thread sendThd = std::thread(send_message);

std::thread recvThd = std::thread(recv_message);

sendThd.join();

recvThd.join();

CGRAPH_CLEAR_MESSAGES();

GPipelineFactory::clear();