Method work_loop

source/executors/thread_pool_executor.cpp:366–380

}

void thread_pool_worker::work_loop() {
    s_tl_thread_pool_data.this_worker = this;
    s_tl_thread_pool_data.this_thread_index = m_index;

    try {
        while (true) {
            if (!drain_queue()) {
                return;
            }
        }
    } catch (const errors::runtime_shutdown&) {
        std::unique_lock<std::mutex> lock(m_lock);
        m_idle = true;
    }
}

void thread_pool_worker::ensure_worker_active(bool first_enqueuer, std::unique_lock<std::mutex>& lock) {
    assert(lock.owns_lock());