diff --git a/src/docker_data/mod.rs b/src/docker_data/mod.rs index 09ee6e7..43a2124 100644 --- a/src/docker_data/mod.rs +++ b/src/docker_data/mod.rs @@ -405,7 +405,7 @@ impl DockerData { .values() .into_iter() .for_each(tokio::task::JoinHandle::abort); - self.is_running.store(false, Ordering::Relaxed); + self.is_running.store(false, Ordering::SeqCst); } } } diff --git a/src/input_handler/mod.rs b/src/input_handler/mod.rs index 97472b9..b99c5be 100644 --- a/src/input_handler/mod.rs +++ b/src/input_handler/mod.rs @@ -73,7 +73,7 @@ impl InputHandler { } } } - if !self.is_running.load(Ordering::Relaxed) { + if !self.is_running.load(Ordering::SeqCst) { break; } } @@ -134,7 +134,7 @@ impl InputHandler { .lock() .status_contains(&[Status::Error, Status::Init]); if error_init || self.docker_sender.send(DockerMessage::Quit).await.is_err() { - self.is_running.store(false, Ordering::Relaxed); + self.is_running.store(false, Ordering::SeqCst); } } diff --git a/src/ui/mod.rs b/src/ui/mod.rs index 32d387e..b5a8c80 100644 --- a/src/ui/mod.rs +++ b/src/ui/mod.rs @@ -98,7 +98,7 @@ async fn run_app( } } } else { - while is_running.load(Ordering::Relaxed) { + while is_running.load(Ordering::SeqCst) { if crossterm::event::poll(input_poll_rate).unwrap_or(false) { if let Ok(event) = event::read() { if let Event::Key(key) = event {