use an AtomicBoolean instead

census-instrumentation · May 10, 2018 · 2b72a3e · 2b72a3e
1 parent 41c8e0e
commit 2b72a3e
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/impl/src/main/java/io/opencensus/impl/internal/DisruptorEventQueue.java b/impl/src/main/java/io/opencensus/impl/internal/DisruptorEventQueue.java
@@ -24,6 +24,7 @@
 import com.lmax.disruptor.dsl.ProducerType;
 import io.opencensus.implcore.internal.DaemonThreadFactory;
 import io.opencensus.implcore.internal.EventQueue;
+import java.util.concurrent.atomic.AtomicBoolean;
 import java.util.logging.Level;
 import java.util.logging.Logger;
 import javax.annotation.Nullable;
@@ -162,12 +163,11 @@ public void enqueue(Entry entry) {
   public void shutdown() {
     enqueuer =
         new DisruptorEnqueuer() {
-          boolean logged = false;
+          final AtomicBoolean logged = new AtomicBoolean(false);
 
           @Override
           public void enqueue(Entry entry) {
-            if (!logged) {
-              logged = true;
+            if (!logged.getAndSet(true)) {
               logger.log(Level.INFO, "Attempted to enqueue entry after Disruptor shutdown.");
             }
           }