Method enqueue_foreign

source/executors/thread_pool_executor.cpp:412–423

}

void thread_pool_worker::enqueue_foreign(concurrencpp::task& task) {
    std::unique_lock<std::mutex> lock(m_lock);
    if (m_abort) {
        throw_runtime_shutdown_exception(m_parent_pool.name);
    }

    m_task_found_or_abort.store(true, std::memory_order_relaxed);

    const auto is_empty = m_public_queue.empty();
    m_public_queue.emplace_back(std::move(task));
    ensure_worker_active(is_empty, lock);
}

void thread_pool_worker::enqueue_foreign(std::span<concurrencpp::task> tasks) {
    std::unique_lock<std::mutex> lock(m_lock);