in benches/counter.rs [34:52]
fn counter_sync(scheduler: impl Scheduler + 'static) {
let runner = Runner::new(scheduler, Default::default());
runner.run(|| {
let counter = Arc::new(AtomicUsize::new(0usize));
let tasks: Vec<_> = (0..NUM_TASKS)
.map(|_| {
let counter = Arc::clone(&counter);
thread::spawn(move || {
counter.fetch_add(1, Ordering::SeqCst);
})
})
.collect();
for t in tasks {
t.join().unwrap();
}
});
}