Struct Scheduler 

pub struct Scheduler {
    pub leases: LeaseTable,
    /* private fields */
}

The mutable parallel scheduler.

Fields

leases: LeaseTable

Implementations

impl Scheduler

pub fn new(max_parallel: usize) -> Self

pub fn running_count(&self) -> usize

pub fn ready_nodes<'a, F>( &self, revision: &'a WorkGraphRevision, footprint_of: F, ) -> Vec<&'a WorkNode>

where F: Fn(&WorkNode) -> Footprint,

Compute the ready set: pending nodes whose dependencies are all accepted, whose required sensors are resolved, and whose footprints do not conflict with currently-running tasks. footprint_of supplies each node’s footprint (domain-derived from output targets and edges).

pub fn start(&mut self, node: &WorkNode, footprint: Footprint)

Mark a node as running, occupying its footprint.

pub fn finish(&mut self, node_id: &str, generation: u32)

Mark a running node as finished, freeing its footprint.

Trait Implementations

impl Debug for Scheduler

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.