Method finalize

src/Common/ThreadPool.cpp:255–295

template <typename Thread>
void ThreadPoolImpl<Thread>::finalize()
{
    {
        std::unique_lock lock(mutex);
        shutdown = true;
        /// We don't want threads to remove themselves from `threads` anymore, otherwise `thread.join()` will go wrong below in this function.
        threads_remove_themselves = false;
    }

    new_job_or_shutdown.notify_all();

    std::vector<size_t> tids;
    std::stringstream ss;
    ss << "[";
    tids.reserve(threads.size());

    for (auto & thread : threads)
    {
        thread.join();
        if constexpr (std::is_same_v<ThreadFromGlobalPool, Thread>)
        {
            tids.emplace_back(thread.gettid());
            ss << thread.gettid() << ", ";
        }
    }
    ss << "]";


    if (!tids.empty())
    {
        auto & cgroup_manager = DB::CGroupManagerFactory::instance();
        if (cgroup_manager.isInit() && cpu_set)
        {
            DB::CpuSetPtr system_cpu_set = cgroup_manager.getSystemCpuSet();
            system_cpu_set->addTasks(tids);
        }
        LOG_DEBUG(&Poco::Logger::get("ThreadPool"), "clear thread for finalize : {}", ss.str());
    }

    threads.clear();
}

template <typename Thread>
size_t ThreadPoolImpl<Thread>::active() const