Method ensure_worker_active

source/executors/thread_pool_executor.cpp:382–410

}

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

    if (!m_idle) {
        lock.unlock();

        if (first_enqueuer) {
            m_semaphore.release();
        }

        return;
    }

    auto stale_worker = std::move(m_thread);
    m_thread = thread(
        m_worker_name,
        [this] {
            work_loop();
        },
        m_thread_started_callback,
        m_thread_terminated_callback);

    m_idle = false;
    lock.unlock();

    if (stale_worker.joinable()) {
        stale_worker.join();
    }
}

void thread_pool_worker::enqueue_foreign(concurrencpp::task& task) {
    std::unique_lock<std::mutex> lock(m_lock);