process_default()

void MayaFlux::Vruta::TaskScheduler::process_default ( ProcessingToken  token, uint64_t  processing_units  )

private

Process tasks in a specific domain with default algorithm.

Parameters

token	Processing domain
processing_units	Number of units to process

Definition at line 386 of file Scheduler.cpp.

{
    auto clock_it = m_token_clocks.find(token);
    if (clock_it == m_token_clocks.end()) {
        return;
    }
 
    auto tasks = get_tasks_for_token(token);
    if (tasks.empty()) {
        auto& clock = *clock_it->second;
        clock.tick(processing_units);
        return;
    }
 
    auto& clock = *clock_it->second;
 
    for (uint64_t i = 0; i < processing_units; i++) {
        uint64_t current_context = clock.current_position();
 
        for (auto& routine : tasks) {
            if (routine && routine->is_active()) {
                if (routine->requires_clock_sync()) {
                    if (current_context >= routine->next_execution()) {
                        routine->try_resume_with_context(current_context, DelayContext::SAMPLE_BASED);
                    }
                } else {
                    routine->try_resume_with_context(current_context, DelayContext::SAMPLE_BASED);
                }
            }
        }
 
        clock.tick(1);
    }
}

References get_tasks_for_token(), m_token_clocks, and MayaFlux::Vruta::SAMPLE_BASED.

Referenced by process_token().

Here is the call graph for this function:

Here is the caller graph for this function: