Method wait_for_task

source/executors/worker_thread_executor.cpp:42–58

}

void worker_thread_executor::wait_for_task(std::unique_lock<std::mutex>& lock) {
    assert(lock.owns_lock());
    if (!m_public_queue.empty() || m_abort) {
        return;
    }

    while (true) {
        lock.unlock();

        m_semaphore.acquire();

        lock.lock();
        if (!m_public_queue.empty() || m_abort) {
            break;
        }
    }
}

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