Lines Matching refs:Relaxed
14 use std::sync::atomic::Ordering::Relaxed;
54 let num = cnt.fetch_add(1, Relaxed) + 1; in many_oneshot_futures()
254 self.0.fetch_add(1, Relaxed); in drop_threadpool_drops_futures()
264 a.fetch_add(1, Relaxed); in drop_threadpool_drops_futures()
267 b.fetch_add(1, Relaxed); in drop_threadpool_drops_futures()
278 let a = num_inc.load(Relaxed); in drop_threadpool_drops_futures()
282 let b = num_dec.load(Relaxed); in drop_threadpool_drops_futures()
286 let c = num_drop.load(Relaxed); in drop_threadpool_drops_futures()
303 after_inner.clone().fetch_add(1, Ordering::Relaxed); in start_stop_callbacks_called()
306 before_inner.clone().fetch_add(1, Ordering::Relaxed); in start_stop_callbacks_called()
321 assert!(after_start.load(Ordering::Relaxed) > 0); in start_stop_callbacks_called()
322 assert!(before_stop.load(Ordering::Relaxed) > 0); in start_stop_callbacks_called()
357 let num = cnt.fetch_add(1, Relaxed) + 1; in blocking()
511 set.spawn(async move { cnt.fetch_add(1, Ordering::Relaxed) }); in global_queue_interval_set_to_one()
518 assert_eq!(cnt.load(Relaxed), 10); in global_queue_interval_set_to_one()
668 if flag.load(Relaxed) { in test_tuning()
673 counter.fetch_add(1, Relaxed); in test_tuning()
691 let curr = interval.load(Relaxed); in test_tuning()
711 let prev = counter.swap(0, Relaxed); in test_tuning()
712 interval.store(prev, Relaxed); in test_tuning()
719 flag.store(false, Relaxed); in test_tuning()
743 let curr = interval.load(Relaxed); in test_tuning()
760 let prev = counter.swap(0, Relaxed); in test_tuning()
761 interval.store(prev, Relaxed); in test_tuning()
768 flag.store(false, Relaxed); in test_tuning()