Struct TaskGraph 

pub struct TaskGraph { /* private fields */ }

DAG of tasks with dependency tracking. Maintains an in-degree counter so ready_tasks() is O(1) amortized.

Implementations

impl TaskGraph

pub fn new() -> Self

pub fn add(&mut self, task: RuntimeTask, dependencies: Vec<usize>) -> usize

Add a task, returns its ID.

pub fn topological_sort(&self) -> Result<Vec<usize>>

Topological sort — returns ordered IDs or error if cycle detected.

pub fn ready_tasks(&self) -> Vec<usize>

Return IDs of tasks that are Ready (deps satisfied, not yet started).

pub fn start(&mut self, task_id: usize)

Mark a task as running.

pub fn set_ready(&mut self, task_id: usize)

Re-mark a (running) task as Ready without touching dependents — used to re-arm a loop node for its next iteration. Unlike complete, this does NOT decrement any in-degree, so the loop node’s dependents stay pending until the loop finally completes.

pub fn complete(&mut self, task_id: usize, result: LoopResult)

Mark a task as completed; promote dependents whose in-degree reaches 0.

pub fn fail(&mut self, task_id: usize)

Mark a task as failed (dependents remain Pending — caller decides policy).

pub fn get(&self, task_id: usize) -> Option<&TaskNode>

pub fn len(&self) -> usize

pub fn is_empty(&self) -> bool

pub fn all_done(&self) -> bool

Trait Implementations

impl Default for TaskGraph

fn default() -> Self

Returns the “default value” for a type.