Struct ParallelProcessor 

pub struct ParallelProcessor { /* private fields */ }

Parallel processor for batch operations

Implementations

impl ParallelProcessor

pub fn new(num_threads: usize) -> Self

Create a new parallel processor with the specified number of threads

pub fn num_threads(&self) -> usize

Get the number of threads

pub fn config(&self) -> ParallelConfig

Get processor configuration

pub fn execute_parallel<T, F>(&self, items: Vec<T>, f: F) -> Vec<T>

where T: Send + Sync, F: Fn(&T) -> T + Send + Sync,

Execute work in parallel

pub fn get_statistics(&self) -> ParallelStatistics

Get processing statistics

pub fn should_use_parallel(&self, item_count: usize) -> bool

Determine if parallel processing should be used

Trait Implementations

impl Clone for ParallelProcessor

fn clone(&self) -> ParallelProcessor

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ParallelProcessor

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for ParallelProcessor

fn default() -> Self

Returns the “default value” for a type.