add_task()

void MayaFlux::Vruta::TaskScheduler::add_task	(	std::shared_ptr< Routine >	routine,
		const std::string &	name = "",
		bool	initialize = false
	)

Add a routine to the scheduler based on its processing token.

Parameters

routine	Routine to add (SoundRoutine, GraphicsRoutine, or ComplexRoutine)
name	Optional name for the routine (for task management)
initialize	Whether to initialize the routine's state immediately

The routine's processing token determines which domain it belongs to and which clock it synchronizes with. Automatically dispatches to the appropriate token-specific task list and clock synchronization.

Definition at line 17 of file Scheduler.cpp.

{
    if (!routine) {
        std::cerr << "Failed to initiate routine\n;\t >> Exiting" << std::endl;
        return;
    }
 
    std::string task_name = name.empty() ? auto_generate_name(routine) : name;
    ProcessingToken token = routine->get_processing_token();
 
    {
        auto existing_it = find_task_by_name(task_name);
        if (existing_it != m_tasks.end()) {
            if (existing_it->routine && existing_it->routine->is_active()) {
                existing_it->routine->set_should_terminate(true);
            }
            m_tasks.erase(existing_it);
        }
 
        m_tasks.emplace_back(routine, task_name);
    }
 
    if (initialize) {
        ensure_domain(token);
        initialize_routine_state(routine, token);
    } else {
        ensure_domain(token);
    }
}

References auto_generate_name(), ensure_domain(), find_task_by_name(), initialize(), initialize_routine_state(), m_tasks, and token.

Referenced by MayaFlux::Kriya::BufferPipeline::dispatch_branch_async(), MayaFlux::Kriya::BufferPipeline::execute_buffer_rate(), MayaFlux::Kriya::BufferPipeline::execute_for_cycles(), MayaFlux::Kriya::BufferPipeline::execute_once(), MayaFlux::Kriya::BufferPipeline::execute_scheduled(), MayaFlux::Kriya::Timer::schedule(), and MayaFlux::Kriya::EventChain::start().

Here is the call graph for this function:

Here is the caller graph for this function: