Method dispatch

src/UtilsCtrl/ThreadPool/UThreadPool.cpp:134–154

CIndex UThreadPool::dispatch(CIndex origIndex) {
    if (unlikely(config_.fair_lock_enable_)) {
        return CGRAPH_DEFAULT_TASK_STRATEGY;    // 如果开启fair lock，则全部写入 pool的queue中，依次执行
    }

    CIndex realIndex = 0;
    if (CGRAPH_DEFAULT_TASK_STRATEGY == origIndex) {
        /**
         * 如果是默认策略信息，在[0, default_thread_size_) 之间的，通过 thread 中queue来调度
         * 在[default_thread_size_, max_thread_size_) 之间的，通过 pool 中的queue来调度
         */
        realIndex = cur_index_++;
        if (cur_index_ >= config_.max_thread_size_ || cur_index_ < 0) {
            cur_index_ = 0;
        }
    } else {
        realIndex = origIndex;
    }

    return realIndex;    // 交到上游去判断，走哪个线程
}


CStatus UThreadPool::createSecondaryThread(CInt size) {