Method finalize

src/Common/ThreadPool.cpp:562–591

template <typename Thread>
void ThreadPoolImpl<Thread>::finalize()
{
    {
        std::lock_guard lock(mutex);
        shutdown = true;

        /// scheduleImpl doesn't check for shutdown outside the critical section,
        /// so we set remaining_pool_capacity to a large negative value
        /// (e.g., -MAX_THEORETICAL_THREAD_COUNT) to signal that no new threads are needed.
        /// This effectively prevents any new threads from being started during shutdown.
        remaining_pool_capacity.store(-MAX_THEORETICAL_THREAD_COUNT, std::memory_order_relaxed);

        /// Disable thread self-removal from `threads`. Otherwise, if threads remove themselves,
        /// the thread.join() operation will fail later in this function.
        threads_remove_themselves = false;

        /// Wake up all idle threads so they can see shutdown and exit gracefully.
        wakeUpAllIdleThreadsNoLock();
    }

    /// Join all threads before clearing the list
    for (auto& thread_ptr : threads)
    {
        if (thread_ptr)
            thread_ptr->join();
    }

    // now it's safe to clear the threads
    threads.clear();
}

template <typename Thread>
void ThreadPoolImpl<Thread>::addOnDestroyCallback(OnDestroyCallback && callback)