Method shutdown

source/executors/worker_thread_executor.cpp:168–197

}

void worker_thread_executor::shutdown() {
    const auto abort = m_atomic_abort.exchange(true, std::memory_order_relaxed);
    if (abort) {
        return;  // shutdown had been called before.
    }

    {
        std::unique_lock<std::mutex> lock(m_lock);
        m_abort = true;
    }

    m_private_atomic_abort.store(true, std::memory_order_relaxed);
    m_semaphore.release();

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

    decltype(m_private_queue) private_queue;
    decltype(m_public_queue) public_queue;

    {
        std::unique_lock<std::mutex> lock(m_lock);
        private_queue = std::move(m_private_queue);
        public_queue = std::move(m_public_queue);
    }

    private_queue.clear();
    public_queue.clear();
}