Method submit

src/UtilsCtrl/ThreadPool/UThreadPool.cpp:92–121

CStatus UThreadPool::submit(const UTaskGroup& taskGroup, const CMSec ttl) {
    CGRAPH_FUNCTION_BEGIN
    CGRAPH_ASSERT_INIT(true)

    std::vector<std::future<CVoid>> futures;
    futures.reserve(taskGroup.getSize());
    for (const auto& task : taskGroup.task_arr_) {
        futures.emplace_back(commit(task));
    }

    // 计算最终运行时间信息
    const auto& deadline = std::chrono::steady_clock::now()
                    + std::chrono::milliseconds(std::min(taskGroup.getTtl(), ttl));

    for (auto& fut : futures) {
        const auto& futStatus = fut.wait_until(deadline);
        switch (futStatus) {
            case std::future_status::ready: break;    // 正常情况，直接返回了
            case std::future_status::timeout: status += CStatus("thread status timeout"); break;
            case std::future_status::deferred: status += CStatus("thread status deferred"); break;
            default: status += CStatus("thread status unknown");
        }
    }

    if (taskGroup.on_finished_) {
        taskGroup.on_finished_(status);
    }

    CGRAPH_FUNCTION_END
}


CStatus UThreadPool::submit(CGRAPH_DEFAULT_CONST_FUNCTION_REF func, const CMSec ttl,