pump_conditional()

void MayaFlux::Vruta::TaskScheduler::pump_conditional ( )

private

Pump the conditional task list in a separate thread.

This method runs in a dedicated thread and continuously checks for conditional tasks that are ready to execute. It processes these tasks based on their conditions and ensures they are executed as soon as their conditions are met.

Definition at line 685 of file Scheduler.cpp.

{
    drain_conditional_pending();
 
    if (m_conditional_tasks.empty()) {
        std::this_thread::yield();
        return;
    }
 
    std::erase_if(m_conditional_tasks, [](const TaskEntry& e) {
        return !e.routine || !e.routine->is_active();
    });
 
    for (auto& entry : m_conditional_tasks) {
        if (entry.routine && entry.routine->is_active())
            entry.routine->try_resume(0);
    }
}

References drain_conditional_pending(), m_conditional_tasks, and MayaFlux::Vruta::TaskEntry::routine.

Referenced by start_conditional_thread().

Here is the call graph for this function:

Here is the caller graph for this function: