aboutsummaryrefslogtreecommitdiff
path: root/vendor/rayon/tests/cross-pool.rs
diff options
context:
space:
mode:
authorValentin Popov <valentin@popov.link>2024-07-19 15:37:58 +0300
committerValentin Popov <valentin@popov.link>2024-07-19 15:37:58 +0300
commita990de90fe41456a23e58bd087d2f107d321f3a1 (patch)
tree15afc392522a9e85dc3332235e311b7d39352ea9 /vendor/rayon/tests/cross-pool.rs
parent3d48cd3f81164bbfc1a755dc1d4a9a02f98c8ddd (diff)
downloadfparkan-a990de90fe41456a23e58bd087d2f107d321f3a1.tar.xz
fparkan-a990de90fe41456a23e58bd087d2f107d321f3a1.zip
Deleted vendor folder
Diffstat (limited to 'vendor/rayon/tests/cross-pool.rs')
-rw-r--r--vendor/rayon/tests/cross-pool.rs22
1 files changed, 0 insertions, 22 deletions
diff --git a/vendor/rayon/tests/cross-pool.rs b/vendor/rayon/tests/cross-pool.rs
deleted file mode 100644
index 835e2e2..0000000
--- a/vendor/rayon/tests/cross-pool.rs
+++ /dev/null
@@ -1,22 +0,0 @@
-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);
-}