drain_conditional_pending()

void MayaFlux::Vruta::TaskScheduler::drain_conditional_pending ( )

private

Drain pending conditional task operations before processing.

Similar to drain_pending_tasks, but specifically for conditional tasks that may have been added or removed while the conditional processing thread is running.

Definition at line 741 of file Scheduler.cpp.

{
    if (m_conditional_pending_count.load(std::memory_order_acquire) == 0)
        return;
 
    DrainScope drain_scope(this);
 
    for (auto& op : m_conditional_pending_ops) {
        if (!op.active.load(std::memory_order_acquire))
            continue;
 
        if (op.is_addition) {
            auto it = std::ranges::find_if(m_conditional_tasks,
                [&](const TaskEntry& e) { return e.name == op.entry.name; });
            if (it != m_conditional_tasks.end()) {
                if (it->routine && it->routine->is_active())
                    it->routine->set_should_terminate(true);
                m_conditional_tasks.erase(it);
            }
            m_conditional_tasks.push_back(std::move(op.entry));
        } else {
            auto it = std::ranges::find_if(m_conditional_tasks,
                [&](const TaskEntry& e) { return e.name == op.entry.name; });
            if (it != m_conditional_tasks.end()) {
                if (it->routine && it->routine->is_active())
                    it->routine->set_should_terminate(true);
                m_conditional_tasks.erase(it);
            }
        }
 
        op.entry = { nullptr, "" };
        op.active.store(false, std::memory_order_release);
        m_conditional_pending_count.fetch_sub(1, std::memory_order_relaxed);
    }
}

References m_conditional_pending_count, m_conditional_pending_ops, m_conditional_tasks, and MayaFlux::Vruta::TaskEntry::name.

Referenced by pump_conditional(), and terminate_all_tasks().

Here is the caller graph for this function: