Struct ParallelFileProcessor 

pub struct ParallelFileProcessor { /* private fields */ }

Parallel file processor with advanced features

Implementations

impl ParallelFileProcessor

pub fn new() -> Self

Create a new parallel file processor

pub fn process_files<P, F>( &self, files: Vec<P>, processor: F, progress_message: &str, ) -> Result<Vec<Result<()>>>

where P: AsRef<Path> + Send + Sync, F: Fn(&Path) -> Result<()> + Send + Sync,

Process files in parallel with a custom function

pub fn process_files_with_results<P, T, F>( &self, files: Vec<P>, processor: F, progress_message: &str, ) -> Result<Vec<(PathBuf, Result<T>)>>

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

Process files with result collection

pub fn add_bytes(&self, bytes: u64)

Add bytes processed

pub fn stats(&self) -> (usize, usize, u64)

Get statistics

pub fn error_collector(&self) -> &ErrorCollector

Get error collector

Trait Implementations

impl Default for ParallelFileProcessor

fn default() -> Self

Returns the “default value” for a type.