Function example_third_flow

example/E03-ThirdFlow.cpp:101–119

};

void example_third_flow() {
    CGRAPH_CREATE_MESSAGE_TOPIC(InputMParam, INPUT_TOPIC_NAME, 16);
    CGRAPH_CREATE_MESSAGE_TOPIC(ResultMParam, RESULT_TOPIC_NAME, 16);

    auto pipeline = GPipelineFactory::create();
    GElementPtr input, process, result = nullptr;
    pipeline->registerGElement<InputGNode>(&input);
    pipeline->registerGElement<ProcessGNode>(&process);
    pipeline->registerGElement<ResultGNode>(&result);

    UThreadPoolConfig config;
    config.default_thread_size_ = 3;
    config.secondary_thread_size_ = 0;
    pipeline->setUniqueThreadPoolConfig(config);    // 设置3个线程执行

    pipeline->process();
    CGRAPH_CLEAR_MESSAGES()
    GPipelineFactory::clear();
}

int main() {
    example_third_flow();