Method startMoreThreadsIfNeeded

src/Common/threadPoolCallbackRunner.cpp:55–62

}

void ThreadPoolCallbackRunnerFast::startMoreThreadsIfNeeded(size_t active_tasks_, std::unique_lock<std::mutex> &)
{
    while (threads < max_threads && threads < active_tasks_ && !shutdown_requested)
    {
        pool->scheduleOrThrow([this] { threadFunction(); });
        ++threads; // only if scheduleOrThrow didn't throw
    }
}

void ThreadPoolCallbackRunnerFast::operator()(std::function<void()> f)
{