Struct ParallelLevelUpdater 

pub struct ParallelLevelUpdater { /* private fields */ }

Parallel level updater using Rayon

Implementations

impl ParallelLevelUpdater

pub fn new() -> Self

Create new parallel updater with default config

pub fn with_config(config: ParallelConfig) -> Self

Create with custom config

pub fn try_update_min(&self, value: f64, level: usize) -> bool

Update global minimum atomically

pub fn global_min(&self) -> f64

Get current global minimum

pub fn best_level(&self) -> Option<usize>

Get best level

pub fn reset_min(&self)

Reset global minimum

pub fn process_parallel<F>( &self, levels: &[usize], process_fn: F, ) -> Vec<LevelUpdateResult>

where F: FnMut(usize) -> LevelUpdateResult + Clone,

Process levels in parallel (scalar fallback)

pub fn process_with_stealing<F>( &self, work_items: Vec<WorkItem>, process_fn: F, ) -> Vec<LevelUpdateResult>

where F: Fn(&WorkItem) -> LevelUpdateResult,

Process work items (scalar fallback)

pub fn process_vertices_parallel<F, R>( &self, vertices: &[VertexId], process_fn: F, ) -> Vec<R>

where F: Fn(VertexId) -> R,

Batch vertex processing (scalar fallback)

pub fn parallel_reduce<T, F, R>( &self, items: &[T], identity: R, map_fn: F, reduce_fn: fn(R, R) -> R, ) -> R

where F: Fn(&T) -> R, R: Clone,

Parallel reduction (scalar fallback)

pub fn scheduler(&self) -> &Arc<WorkStealingScheduler>

Get scheduler reference

Trait Implementations

impl Default for ParallelLevelUpdater

fn default() -> Self

Returns the “default value” for a type.