Method drain_queue_impl

source/executors/thread_pool_executor.cpp:317–341

}

bool thread_pool_worker::drain_queue_impl() {
    auto aborted = false;

    while (!m_private_queue.empty()) {
        balance_work();

        if (m_atomic_abort.load(std::memory_order_relaxed)) {
            aborted = true;
            break;
        }

        assert(!m_private_queue.empty());
        auto task = std::move(m_private_queue.back());
        m_private_queue.pop_back();
        task();
    }

    if (aborted) {
        std::unique_lock<std::mutex> lock(m_lock);
        m_idle = true;
        return false;
    }

    return true;
}

bool thread_pool_worker::drain_queue() {
    std::unique_lock<std::mutex> lock(m_lock);