ordered-parallel-iterator 0.2.0

Performs tasks in parallel returning completed tasks in order of appearance.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

use ordered_parallel_iterator::OrderedParallelIterator;

fn run_me(x: usize) -> usize {
    eprintln!("start {}", x);
    sleep_secs(30 - x);
    eprintln!("end {}", x);
    x
}

fn sleep_secs(secs: usize) {
    std::thread::sleep(std::time::Duration::from_secs(secs as u64));
}

fn main() {
    for i in crate::OrderedParallelIterator::new(|| 0..30, || run_me) {
        eprintln!("consume {}", i);
        sleep_secs(i);
        eprintln!("wake up and took next value");
    }
}