Polish makeStop for ServiceThread

43753d6e · dongeforever · 38554a08 · 43753d6e
显示空白变更内容
内联并排

Showing with 2 addition and 2 deletion

common/src/main/java/org/apache/rocketmq/common/ServiceThread.java ...c/main/java/org/apache/rocketmq/common/ServiceThread.java +2 -2

未找到文件。
--- 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;