cancel_task() [2/2]

bool MayaFlux::Vruta::TaskScheduler::cancel_task

(

const std::string &

name

)

Cancel a task by name.

Parameters

name	Task name to cancel

Returns

True if found and cancelled

Definition at line 149 of file Scheduler.cpp.

{
    SubmissionGuard guard(m_inflight_submissions, m_terminating);
    if (!guard.accepted)
        return false;
 
    bool queued = false;
 
    if (m_conditional_thread.joinable()) {
        for (auto& op : m_conditional_pending_ops) {
            bool expected = false;
            if (op.active.compare_exchange_strong(expected, true,
                    std::memory_order_acquire, std::memory_order_relaxed)) {
                op.entry = { nullptr, name };
                op.is_addition = false;
                m_conditional_pending_count.fetch_add(1, std::memory_order_relaxed);
                queued = true;
                break;
            }
        }
    }
 
    for (auto& op : m_pending_ops) {
        bool expected = false;
        if (op.active.compare_exchange_strong(expected, true,
                std::memory_order_acquire, std::memory_order_relaxed)) {
            op.entry = { nullptr, name };
            op.is_addition = false;
            m_pending_count.fetch_add(1, std::memory_order_relaxed);
            queued = true;
            break;
        }
    }
 
    if (!queued) {
        MF_ERROR(Journal::Component::Vruta, Journal::Context::CoroutineScheduling,
            "Pending task queue full, could not cancel task '{}'", name);
    }
 
    return queued;
}

References MayaFlux::Journal::CoroutineScheduling, m_conditional_pending_count, m_conditional_pending_ops, m_conditional_thread, m_inflight_submissions, m_pending_count, m_pending_ops, m_terminating, MF_ERROR, name, and MayaFlux::Journal::Vruta.