Crate cue [−] [src]
Run a computation in parallel, and register a "joiner" closure to aggregate/serialize the results. Example:
use std::collections::BTreeMap; use cue::pipeline; let mut results = BTreeMap::new(); pipeline("test123", // name of the pipeline for logging 4, // number of worker threads (0..100_000), // iterator with work items |n| (n, n * 5), // computation to apply in parallel to work items |r| { // aggregation to apply to work results results.insert(r.0, r.1); } ); for i in 0..100 { assert!(Some(&(i * 5)) == results.get(&i)); }
Functions
pipeline |