Struct ConcurrentRunner

pub struct ConcurrentRunner<Config> { /* private fields */ }

A runner to process files concurrently.

Implementations

impl<Config: 'static + Send + Sync> ConcurrentRunner<Config>

pub fn new<ProcFiles>(num_jobs: usize, proc_files: ProcFiles) -> Self

where ProcFiles: 'static + Fn(PathBuf, &Config) -> Result<()> + Send + Sync,

Creates a new ConcurrentRunner.

• num_jobs - Number of jobs utilized to process files concurrently.
• proc_files - Function that processes each file found during the search.

pub fn set_proc_dir_paths<ProcDirPaths>( self, proc_dir_paths: ProcDirPaths, ) -> Self

where ProcDirPaths: 'static + Fn(&mut HashMap<String, Vec<PathBuf>>, &Path, &Config) + Send + Sync,

Sets the function to process the paths and subpaths contained in a directory.

pub fn set_proc_path<ProcPath>(self, proc_path: ProcPath) -> Self

where ProcPath: 'static + Fn(&Path, &Config) + Send + Sync,

Sets the function to process a single path.

pub fn run( self, config: Config, files_data: FilesData, ) -> Result<HashMap<String, Vec<PathBuf>>, ConcurrentErrors>

Runs the producer-consumer approach to process the files contained in a directory and in its own subdirectories.

• config - Information used to process a file.
• files_data - Information about the files to be included or excluded from a search more the number of paths considered in the search.