Struct CacheAwareWorkStealer 

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

Cache-aware work-stealing scheduler with memory locality optimization

Implementations

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

pub fn new( _num_workers: usize, strategy: CacheAwareStrategy, ) -> LinalgResult<Self>

Create a new cache-aware work stealer

pub fn execute_cache_aware<F, R>( &self, work_items: Vec<WorkItem<T>>, worker_fn: F, strategy: CacheAwareStrategy, ) -> LinalgResult<Vec<R>>

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

Execute work with cache-aware distribution

pub fn update_cache_miss_rate( &self, worker_id: usize, missrate: f64, ) -> LinalgResult<()>

Update cache miss rate for a worker

pub fn get_numa_optimal_worker(&self, memorynode: usize) -> usize

Get NUMA-aware worker assignment for a task