| 29 | } |
| 30 | |
| 31 | void thread_executor::enqueue(concurrencpp::task task) { |
| 32 | std::unique_lock<std::mutex> lock(m_lock); |
| 33 | if (m_abort) { |
| 34 | details::throw_runtime_shutdown_exception(name); |
| 35 | } |
| 36 | |
| 37 | enqueue_impl(lock, task); |
| 38 | } |
| 39 | |
| 40 | void thread_executor::enqueue(std::span<concurrencpp::task> tasks) { |
| 41 | std::unique_lock<std::mutex> lock(m_lock); |
nothing calls this directly
no outgoing calls
no test coverage detected