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

use super::run_map;
use crate::{
    IterationOrder,
    runner::implementations::{RunnerWithPool, YastlPool},
};
use test_case::test_matrix;
use yastl::ThreadConfig;

#[cfg(miri)]
const N: [usize; 2] = [37, 125];
#[cfg(not(miri))]
const N: [usize; 2] = [1025, 4735];

// TODO: miri test terminates with: the main thread terminated without waiting for all remaining threads
#[cfg(not(miri))]
#[test_matrix(
    [0, 1, N[0], N[1]],
    [1, 4],
    [1, 64],
    [IterationOrder::Ordered, IterationOrder::Arbitrary])
]
fn pool_yastl_map(n: usize, nt: usize, chunk: usize, ordering: IterationOrder) {
    let pool = YastlPool::new(nt);
    let orch: RunnerWithPool<_> = (&pool).into();
    run_map(n, chunk, ordering, orch);

    let pool = YastlPool::with_config(nt, ThreadConfig::new());
    let orch: RunnerWithPool<_> = (pool).into();
    run_map(n, chunk, ordering, orch);
}