| 86 | } |
| 87 | |
| 88 | void worker_thread_executor::enqueue_local(concurrencpp::task& task) { |
| 89 | if (m_private_atomic_abort.load(std::memory_order_relaxed)) { |
| 90 | details::throw_runtime_shutdown_exception(name); |
| 91 | } |
| 92 | |
| 93 | m_private_queue.emplace_back(std::move(task)); |
| 94 | } |
| 95 | |
| 96 | void worker_thread_executor::enqueue_local(std::span<concurrencpp::task> tasks) { |
| 97 | if (m_private_atomic_abort.load(std::memory_order_relaxed)) { |