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 - Total worker budget (one producer thread plus the consumer threads). run always spawns a single producer thread, so the number of consumer threads it spawns is max(2, num_jobs) - 1. This means 0, 1, and 2 all collapse to a single consumer (no panic, no linear scaling below 2); values of 3 or more yield num_jobs - 1 consumers.
• proc_files - Function that processes each file in the list.

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

Runs the producer-consumer pool over the terminal file list in files_data. Each path is dispatched to a worker as a single regular file; this runner performs no directory traversal or glob filtering (the caller resolves and filters the file set — see FilesData).

• config - Information used to process a file.
• files_data - The resolved, terminal file list to process.

Errors

Returns ConcurrentErrors::Thread when any worker thread (the single producer OR one of the num_jobs consumers) cannot be spawned via std::thread::Builder::spawn; ConcurrentErrors::Producer when the producer thread panics and join fails; ConcurrentErrors::Sender when a worker cannot place an item (or the post-dispatch None poison-pill) on the channel; ConcurrentErrors::Receiver when a consumer thread panics and its join fails. Per-file processing errors raised by the user-supplied callback are surfaced through the callback itself, not through this Result.