Method asyncProcess

src/GraphCtrl/GraphEvent/GEvent.cpp:64–82

std::shared_future<CVoid> GEvent::asyncProcess(GEventAsyncStrategy strategy) {
    CGRAPH_ASSERT_NOT_NULL_THROW_ERROR(thread_pool_)
    std::shared_future<CVoid> future = thread_pool_->commit([this] {
        this->trigger(this->param_);
    }, CGRAPH_POOL_TASK_STRATEGY);

    /**
     * 根据具体策略，将 future信息放到对应的容器中
     * 在特定的时间点，等待执行结束
     */
    if (GEventAsyncStrategy::PIPELINE_RUN_FINISH == strategy) {
        CGRAPH_LOCK_GUARD lock(async_run_finished_lock_);
        async_run_finish_futures_.emplace_back(future);
    } else if (GEventAsyncStrategy::PIPELINE_DESTROY == strategy) {
        CGRAPH_LOCK_GUARD lock(async_destroy_lock_);
        async_destroy_futures_.emplace_back(future);
    }
    return future;
}


CVoid GEvent::asyncWait(GEventAsyncStrategy strategy) {