Struct Scheduler 

pub struct Scheduler {
    pub processes: HashMap<Pid, Process>,
    pub ready_queue: VecDeque<Pid>,
    pub next_pid: u64,
    pub registry: HashMap<String, Pid>,
    pub modules: HashMap<String, Module>,
    pub output: Vec<String>,
    pub next_ref: u64,
    pub timers: Vec<Timer>,
}

The scheduler / VM state

Fields

processes: HashMap<Pid, Process>

ready_queue: VecDeque<Pid>

next_pid: u64

registry: HashMap<String, Pid>

Process registry: name -> pid

modules: HashMap<String, Module>

Module registry: name -> module

output: Vec<String>

Output buffer from print instructions

next_ref: u64

Global reference counter for make_ref and timer_ref

timers: Vec<Timer>

Pending timers

Implementations

impl Scheduler

pub fn new() -> Self

pub fn load_module(&mut self, module: Module) -> Result<(), String>

Load a module into the VM.

pub fn take_output(&mut self) -> Vec<String>

Take and clear the output buffer

pub fn spawn(&mut self, code: Vec<Instruction>) -> Pid

Spawn a root process (no parent)

pub fn spawn_with_parent( &mut self, code: Vec<Instruction>, parent: Option<Pid>, ) -> Pid

Spawn a process with an optional parent

pub fn step(&mut self, budget: u32) -> StepResult

Run up to budget reductions, returns whether there’s more work

pub fn process_count(&self) -> (usize, usize, usize, usize)

Get count of processes by status

Trait Implementations

impl Debug for Scheduler

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

Formats the value using the given formatter.

impl Default for Scheduler

fn default() -> Self

Returns the “default value” for a type.