diff --git a/common/src/main/java/org/apache/rocketmq/common/ServiceThread.java b/common/src/main/java/org/apache/rocketmq/common/ServiceThread.java
index 0e33418f1bd5481bb37a16335d4a1a93f0ad175d..ae46e78fa6289a6fd8b500b76fc8cc775ed3f28b 100644
--- a/common/src/main/java/org/apache/rocketmq/common/ServiceThread.java
+++ b/common/src/main/java/org/apache/rocketmq/common/ServiceThread.java
@@ -97,7 +97,7 @@ public abstract class ServiceThread implements Runnable {
 
     @Deprecated
     public void stop(final boolean interrupt) {
-        if (!started.compareAndSet(true, false)) {
+        if (!started.get()) {
             return;
         }
         this.stopped = true;
@@ -113,7 +113,7 @@ public abstract class ServiceThread implements Runnable {
     }
 
     public void makeStop() {
-        if (!started.compareAndSet(true, false)) {
+        if (!started.get()) {
             return;
         }
         this.stopped = true;