Sha256: 3ad469de5a650389699c9ffe5fd78af2bdd46e7140cc05391c60d793fc6f8e98
Contents?: true
Size: 644 Bytes
Versions: 19
Compression:
Stored size: 644 Bytes
Contents
use std::sync::atomic::{AtomicUsize, Ordering};
use std::thread::spawn;
use iana_time_zone::get_timezone;
const THREADS: usize = 10;
const ITERATIONS: usize = 100_000;
static COUNT: AtomicUsize = AtomicUsize::new(0);
fn main() {
let mut threads = Vec::with_capacity(THREADS);
for _ in 0..THREADS {
threads.push(spawn(|| {
for _ in 0..ITERATIONS {
get_timezone().unwrap();
COUNT.fetch_add(1, Ordering::Relaxed);
}
}));
}
for thread in threads {
thread.join().unwrap();
}
assert_eq!(COUNT.load(Ordering::SeqCst), THREADS * ITERATIONS);
}
Version data entries
19 entries across 19 versions & 1 rubygems