Method monitor

src/UtilsCtrl/ThreadPool/UThreadPool.cpp:173–199

CVoid UThreadPool::monitor() {
    while (is_monitor_) {
        while (is_monitor_ && !is_init_) {
            // 如果没有init，则一直处于空跑状态
            CGRAPH_SLEEP_SECOND(1)
        }

        int span = config_.monitor_span_;
        while (is_monitor_ && is_init_ && span--) {
            CGRAPH_SLEEP_SECOND(1)    // 保证可以快速退出
        }

        // 如果 primary线程都在执行，则表示忙碌
        bool busy = std::all_of(primary_threads_.begin(), primary_threads_.end(),
                                [](UThreadPrimaryPtr ptr) { return nullptr != ptr && ptr->is_running_; });

        // 如果忙碌或者priority_task_queue_中有任务，则需要添加 secondary线程
        if (busy || !priority_task_queue_.empty()) {
            createSecondaryThread(1);
        }

        // 判断 secondary 线程是否需要退出
        for (auto iter = secondary_threads_.begin(); iter != secondary_threads_.end(); ) {
            (*iter)->freeze() ? secondary_threads_.erase(iter++) : iter++;
        }
    }
}

CGRAPH_NAMESPACE_END