Struct WorkStealingScheduler 

pub struct WorkStealingScheduler { /* private fields */ }

Work-stealing scheduler for parallel level processing

Implementations

impl WorkStealingScheduler

pub fn new() -> Self

Create new scheduler with default config

pub fn with_config(config: ParallelConfig) -> Self

Create with custom config

pub fn submit(&self, item: WorkItem)

Submit work item

pub fn submit_batch(&self, items: Vec<WorkItem>)

Submit multiple work items

pub fn steal(&self) -> Option<WorkItem>

Try to steal work from queue

pub fn complete(&self, result: LevelUpdateResult)

Record result

pub fn get_results(&self) -> HashMap<usize, LevelUpdateResult>

Get all results

pub fn clear_results(&self)

Clear results

pub fn is_empty(&self) -> bool

Check if queue is empty

pub fn queue_size(&self) -> usize

Get queue size

pub fn steal_count(&self) -> u64

Get total steals

Trait Implementations

impl Default for WorkStealingScheduler

fn default() -> Self

Returns the “default value” for a type.