Sha256: d2ce3b9013f77c955aa02313b27436c5bf760ab0e6a1e7d768effae69b5bdbfe
Contents?: true
Size: 912 Bytes
Versions: 33
Compression:
Stored size: 912 Bytes
Contents
use rayon::prelude::*;
use rayon::ThreadPoolBuilder;
#[test]
#[cfg_attr(any(target_os = "emscripten", target_family = "wasm"), ignore)]
fn cross_pool_busy() {
let pool1 = ThreadPoolBuilder::new().num_threads(1).build().unwrap();
let pool2 = ThreadPoolBuilder::new().num_threads(1).build().unwrap();
let n: i32 = 100;
let sum: i32 = pool1.install(move || {
// Each item will block on pool2, but pool1 can continue processing other work from the
// parallel iterator in the meantime. There's a chance that pool1 will still be awake to
// see the latch set without being tickled, and then it will drop that stack job. The latch
// internals must not assume that the job will still be alive after it's set!
(1..=n)
.into_par_iter()
.map(|i| pool2.install(move || i))
.sum()
});
assert_eq!(sum, n * (n + 1) / 2);
}
Version data entries
33 entries across 33 versions & 1 rubygems