Function init_threads

src/spawn/mod.rs:97–105

(parallel_raw: &Option<String>)

}

pub fn init_threads(parallel_raw: &Option<String>) -> Result<(), AppError> {
	if let Some(ref raw_num) = *parallel_raw {
		let num_threads = raw_num.parse::<usize>()?;
		rayon::ThreadPoolBuilder::new().num_threads(num_threads).build_global().expect(
			"Tried to initialize rayon more than once (this is a software bug on fw side, please file an issue at https://github.com/brocode/fw/issues/new )",
		);
	}
	Ok(())
}

pub fn foreach(maybe_config: Result<Config, AppError>, cmd: &str, tags: &BTreeSet<String>, parallel_raw: &Option<String>) -> Result<(), AppError> {
	let config = maybe_config?;