From 25787928727e403db6bbea80c7fde24d8e03ea2a Mon Sep 17 00:00:00 2001 From: Evan Feenstra Date: Wed, 6 Sep 2023 09:29:39 -0700 Subject: [PATCH] Ordering::SeqCst --- broker/src/looper.rs | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/broker/src/looper.rs b/broker/src/looper.rs index 87298d4..a88adf5 100644 --- a/broker/src/looper.rs +++ b/broker/src/looper.rs @@ -15,16 +15,16 @@ static COUNTER: AtomicU16 = AtomicU16::new(0u16); static CURRENT: AtomicU16 = AtomicU16::new(0u16); pub fn take_a_ticket() -> u16 { - COUNTER.fetch_add(1u16, Ordering::Relaxed) + COUNTER.fetch_add(1u16, Ordering::SeqCst) } pub fn is_my_turn(ticket: u16) -> bool { - let curr = CURRENT.load(Ordering::Relaxed); + let curr = CURRENT.load(Ordering::SeqCst); curr == ticket } pub fn my_turn_is_done() { - CURRENT.fetch_add(1u16, Ordering::Relaxed); + CURRENT.fetch_add(1u16, Ordering::SeqCst); } #[derive(Clone, Debug)]