Function tutorial_multi_pipeline

tutorial/T07-MultiPipeline.cpp:54–90

void tutorial_multi_pipeline() {
    GPipelinePtr pipeline_1 = GPipelineFactory::create();
    GPipelinePtr pipeline_2 = GPipelineFactory::create();
    GPipelinePtr pipeline_3 = GPipelineFactory::create();

    /**
     * 设置个别pipeline的内部 thread pool 资源信息，用以减少整体资源占用（可选）
     * 这里主要是为了说明，多个pipeline一起运行的时候，可以通过接口，针对个别pipeline进行调度资源的设置
     */
    UThreadPoolConfig config;
    config.default_thread_size_ = 4;
    config.max_thread_size_ = 4;
    config.monitor_enable_ = false;
    UThreadPool pool(true, config);    // 开辟一个4个线程的线程池，直接 init，并且参数设置为 config

    /**
     * 本例中，pipeline1 和 pipeline2 的并发逻辑相对简单
     * 通过如下接口，将这两个pipeline中的调度资源，修改为同一个线程池。
     * ps：注意，必须在 pipeline init之前，先init传入的线程池
     */
    pipeline_1->setSharedThreadPool(&pool);
    pipeline_2->setSharedThreadPool(&pool);

    /**
     * 经过上述的设置，pipeline1 和 pipeline2 共享同一个线程池，去调度其中的dag逻辑
     * pipeline3 没有设定，故使用自带的默认线程池完成自己的调度逻辑
     */
    auto result1 = async_pipeline_1(pipeline_1);
    auto result2 = async_pipeline_2(pipeline_2);
    auto result3 = async_pipeline_3(pipeline_3);

    result1.wait();
    result2.wait();
    result3.wait();

    GPipelineFactory::clear();
}


int main() {