Struct WorkStealingScheduler 

pub struct WorkStealingScheduler<T>
where
    T: Send + 'static + Clone,
{ /* private fields */ }

Work-stealing scheduler with dynamic load balancing

Implementations

impl<T: Send + 'static + Clone> WorkStealingScheduler<T>

pub fn new(_numworkers: usize) -> Self

Create a new work-stealing scheduler

pub fn with_strategy( num_workers: usize, strategy: StealingStrategy, params: LoadBalancingParams, ) -> Self

Create a new work-stealing scheduler with custom strategy

pub fn formatrix_operation( num_workers: usize, operation_type: MatrixOperationType, matrixsize: (usize, usize), ) -> Self

Create optimized scheduler for specific matrix operations

pub fn submit_work(&self, items: Vec<WorkItem<T>>) -> LinalgResult<()>

Submit work items to the scheduler

pub fn execute<F, R>(&self, workfn: F) -> LinalgResult<Vec<R>>

where F: Fn(T) -> R + Send + Sync + 'static, R: Send + Clone + 'static, T: Send + 'static,

Execute all work items using the work-stealing scheduler

pub fn get_stats(&self) -> SchedulerStats

Get current scheduler statistics

pub fn optimize_for_workload( &self, workload_characteristics: WorkloadCharacteristics, ) -> LinalgResult<()>

Adaptive performance monitoring and load balancing optimization

pub fn adaptive_chunk_sizing( &self, base_worksize: usize, worker_efficiency: &[f64], ) -> Vec<usize>

Dynamic chunk size adjustment based on performance history

pub fn predict_execution_time(&self, workcomplexity: WorkComplexity) -> Duration

Advanced workload prediction based on execution history