Struct MorselScheduler 

pub struct MorselScheduler { /* private fields */ }

Work-stealing morsel scheduler.

Distributes morsels to worker threads efficiently:

1. Workers check the global injector queue
2. If empty, steal from other workers via stealers

Supports NUMA-aware stealing to minimize cross-node memory access.

Implementations

impl MorselScheduler

pub fn new(num_workers: usize) -> Self

Creates a new scheduler for the given number of workers.

pub fn with_numa_config(num_workers: usize, numa_config: NumaConfig) -> Self

Creates a scheduler with explicit NUMA configuration.

pub fn num_workers(&self) -> usize

Returns the number of workers.

pub fn submit(&self, morsel: Morsel)

Submits a morsel to the global queue.

pub fn submit_batch(&self, morsels: Vec<Morsel>)

Submits multiple morsels to the global queue.

pub fn finish_submission(&self)

Signals that no more morsels will be submitted.

pub fn register_worker(&self, stealer: Stealer<Morsel>) -> usize

Registers a worker’s stealer for work-stealing.

Returns the worker_id assigned.

pub fn get_global_work(&self) -> Option<Morsel>

Gets work from the global queue.

pub fn steal_work(&self, my_id: usize) -> Option<Morsel>

Tries to steal work from other workers.

Uses NUMA-aware stealing: prefers workers on the same NUMA node to minimize cross-node memory access latency.

pub fn worker_node(&self, worker_id: usize) -> NumaNode

Returns the NUMA node for a worker.

pub fn complete_morsel(&self)

Marks a morsel as completed.

Must be called after processing each morsel.

pub fn is_done(&self) -> bool

Returns whether all work is done.

pub fn is_submission_done(&self) -> bool

Returns whether submission is complete.

pub fn active_count(&self) -> usize

Returns the number of active (in-progress) morsels.

pub fn total_submitted(&self) -> usize

Returns the total number of morsels submitted.

Trait Implementations

impl Debug for MorselScheduler

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

Formats the value using the given formatter.