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 71 of file Scheduler.cpp.

{
    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);
            return true;
        }
    }
 
    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);
            return true;
        }
    }
 
    MF_ERROR(Journal::Component::Vruta, Journal::Context::CoroutineScheduling,
        "Pending task queue full, could not cancel task '{}'", name);
 
    return false;
}

References MayaFlux::Journal::CoroutineScheduling, m_conditional_pending_count, m_conditional_pending_ops, m_pending_count, m_pending_ops, MF_ERROR, and MayaFlux::Journal::Vruta.