Method init

src/UtilsCtrl/ThreadPool/UThreadPool.cpp:47–89

CStatus UThreadPool::init() {
    CGRAPH_FUNCTION_BEGIN
    if (is_init_) {
        CGRAPH_FUNCTION_END
    }

    if (config_.monitor_enable_) {
        // 默认不开启监控线程
        monitor_thread_ = std::thread(&UThreadPool::monitor, this);
    }
    thread_record_map_.clear();
    thread_record_map_[std::hash<std::thread::id>{}(std::this_thread::get_id())] = CGRAPH_MAIN_THREAD_ID;
    task_queue_.setup();
    primary_threads_.reserve(config_.default_thread_size_);
    for (int i = 0; i < config_.default_thread_size_; i++) {
        auto* pt = CGRAPH_SAFE_MALLOC_COBJECT(UThreadPrimary);    // 创建核心线程数
        pt->setThreadPoolInfo(i, &task_queue_, &primary_threads_, &config_);
        // 记录线程和匹配id信息
        primary_threads_.emplace_back(pt);
    }

    /**
     * 等待所有thread 设置完毕之后，再进行 init()，
     * 避免在个别的平台上，可能出现 thread竞争访问其他线程、并且导致异常的情况
     * 参考： https://github.com/ChunelFeng/CGraph/issues/309
     */
    for (int i = 0; i < config_.default_thread_size_; i++) {
        status += primary_threads_[i]->init();
        thread_record_map_[std::hash<std::thread::id>{}(primary_threads_[i]->thread_.get_id())] = i;
    }
    CGRAPH_FUNCTION_CHECK_STATUS

    /**
     * 策略更新：
     * 初始化的时候，也可以创建n个辅助线程。目的是为了配合仅使用 pool中 priority_queue 的场景
     * 一般情况下，建议为0。
     */
    status = createSecondaryThread(config_.secondary_thread_size_);
    CGRAPH_FUNCTION_CHECK_STATUS

    is_init_ = true;
    CGRAPH_FUNCTION_END
}


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