Sha256: 9bd7ea27b4f6cf9e3b3486311747e15a3beb9b9d4e48f115d66ed8288ca19d38
Contents?: true
Size: 654 Bytes
Versions: 33
Compression:
Stored size: 654 Bytes
Contents
use std::collections::HashSet;
use rayon::prelude::*;
use rayon::*;
#[test]
#[cfg_attr(any(target_os = "emscripten", target_family = "wasm"), ignore)]
fn named_threads() {
ThreadPoolBuilder::new()
.thread_name(|i| format!("hello-name-test-{}", i))
.build_global()
.unwrap();
const N: usize = 10000;
let thread_names = (0..N)
.into_par_iter()
.flat_map(|_| ::std::thread::current().name().map(str::to_owned))
.collect::<HashSet<String>>();
let all_contains_name = thread_names
.iter()
.all(|name| name.starts_with("hello-name-test-"));
assert!(all_contains_name);
}
Version data entries
33 entries across 33 versions & 1 rubygems