lxy/redkale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

优化MessageProducer的closed

Browse Source
This commit is contained in:
redkale
2023-02-01 19:53:55 +08:00
parent 78f969d2cc
commit 851c81e096
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
src/main/java/org/redkale/mq/MessageProducer.java
View File

@@ -6,6 +6,7 @@
package org.redkale.mq; package org.redkale.mq;
import java.util.concurrent.CompletableFuture; import java.util.concurrent.CompletableFuture;
import java.util.concurrent.atomic.AtomicBoolean;
import java.util.logging.Logger; import java.util.logging.Logger;
/** /**
@@ -23,7 +24,7 @@ public abstract class MessageProducer {
protected final String name; protected final String name;
protected volatile boolean closed; protected final AtomicBoolean closed = new AtomicBoolean();
protected MessageProducer(String name, Logger logger) { protected MessageProducer(String name, Logger logger) {
this.name = name; this.name = name;
@@ -35,7 +36,7 @@ public abstract class MessageProducer {
public abstract CompletableFuture<Void> startup(); public abstract CompletableFuture<Void> startup();
public boolean isClosed() { public boolean isClosed() {
return closed; return closed.get();
} }
public abstract CompletableFuture<Void> shutdown(); public abstract CompletableFuture<Void> shutdown();