orx-parallel 3.4.0

High performance, configurable and expressive parallel computation library.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46

use orx_parallel::*;
use std::sync::mpsc::channel;

// taken from rayon's documentation:
// https://docs.rs/rayon/1.10.0/rayon/iter/trait.ParallelIterator.html#method.map
fn for_each() {
    let (sender, receiver) = channel();

    (0..5)
        .into_par()
        .using_clone(sender)
        .for_each(|s, x| s.send(x).unwrap());

    let mut res: Vec<_> = receiver.iter().collect();

    res.sort();

    assert_eq!(&res[..], &[0, 1, 2, 3, 4])
}

// taken from rayon's documentation:
// https://docs.rs/rayon/1.10.0/rayon/iter/trait.ParallelIterator.html#method.map
fn map() {
    let (sender, receiver) = channel();

    let a: Vec<_> = (0..5)
        .into_par() // iterating over i32
        .using_clone(sender)
        .map(|s, x| {
            s.send(x).unwrap(); // sending i32 values through the channel
            x // returning i32
        })
        .collect(); // collecting the returned values into a vector

    let mut b: Vec<_> = receiver
        .iter() // iterating over the values in the channel
        .collect(); // and collecting them
    b.sort();

    assert_eq!(a, b);
}

fn main() {
    for_each();
    map();
}