Struct WorkStealingScheduler 

pub struct WorkStealingScheduler { /* private fields */ }

Work-stealing scheduler.

Implementations

impl WorkStealingScheduler

pub fn new(config: ParallelConfig) -> Self

Create a new work-stealing scheduler.

pub fn submit(&self, task: Task) -> Result<(), ParallelError>

Submit a task to the scheduler.

pub fn submit_batch(&self, tasks: Vec<Task>) -> Result<(), ParallelError>

Submit multiple tasks.

pub fn execute_all(&self) -> Result<Vec<TaskId>, ParallelError>

Execute all submitted tasks.

pub fn stats(&self) -> SchedulerStats

Get scheduler statistics.

pub fn reset(&self)

Reset the scheduler.

pub fn try_steal(&self, thief_idx: usize) -> Option<Task>

Attempt to steal work from another worker.

pub fn load_balance_stats(&self) -> LoadBalanceStats

Get load balancing statistics.