moirai-parallel 0.7.0

Synchronous data-parallel primitives (rayon-style) for the Moirai runtime
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

use crate::policy::ExecutionPolicy;
use std::sync::Mutex;

/// Last `(len, chunks, bytes)` the operator reported to a policy.
pub(super) static REPORTED: Mutex<Option<(usize, usize, usize)>> = Mutex::new(None);

pub(super) struct Reporting;

impl ExecutionPolicy for Reporting {
    fn parallelize(_len: usize) -> bool {
        false
    }

    fn parallelize_work(len: usize, chunks: usize, bytes: usize) -> bool {
        *REPORTED.lock().expect("the reporting policy never panics") = Some((len, chunks, bytes));
        false
    }
}

mod many;
mod pair;
mod range;
mod single;
mod triple;

/// Bytes per unit that makes a task carry exactly four units.
pub(super) const FOUR_UNITS: usize = super::UNIT_TASK_BYTES / 4;