Struct ParallelProcessor 

pub struct ParallelProcessor { /* private fields */ }

Parallel processor for batch operations

Implementations

impl ParallelProcessor

pub fn new() -> Self

Create a new parallel processor with default options

pub fn with_options(options: ParallelOptions) -> Self

Create a parallel processor with specific options

pub fn with_progress<F>(self, callback: F) -> Self

where F: Fn(usize, usize) + Send + Sync + 'static,

Set a progress callback

pub fn process<T, E, F>( &self, items: &[PathBuf], processor: F, ) -> ParallelResult<T>

where F: Fn(&Path) -> Result<T, E> + Sync + Send, E: Display, T: Send,

Process items in parallel

pub fn map<T, F>(&self, items: &[PathBuf], mapper: F) -> Vec<T>

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

Process items with a simple function (no error handling)

Trait Implementations

impl Default for ParallelProcessor

fn default() -> Self

Returns the “default value” for a type.