Use LinkedBlockingQueue instead of ArrayBlockingQueue.

Alluxio · Aug 21, 2017 · 1fa43a5 · 1fa43a5
1 parent 7270199
commit 1fa43a5
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/core/server/common/src/main/java/alluxio/master/audit/AsyncUserAccessAuditLogWriter.java b/core/server/common/src/main/java/alluxio/master/audit/AsyncUserAccessAuditLogWriter.java
@@ -6,7 +6,7 @@
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-import java.util.concurrent.ArrayBlockingQueue;
+import java.util.concurrent.LinkedBlockingQueue;
 import java.util.concurrent.TimeUnit;
 import javax.annotation.concurrent.ThreadSafe;
 
@@ -17,12 +17,12 @@ public final class AsyncUserAccessAuditLogWriter {
   private static final Logger LOG = LoggerFactory.getLogger(AsyncUserAccessAuditLogWriter.class);
   private final boolean mEnabled;
   private volatile boolean mStopped;
-  private ArrayBlockingQueue<AuditContext> mAuditLogEntries;
+  private LinkedBlockingQueue<AuditContext> mAuditLogEntries;
 
   public AsyncUserAccessAuditLogWriter() {
     mEnabled = Boolean.parseBoolean(Configuration.get(PropertyKey.MASTER_AUDIT_LOGGING_ENABLED));
     if (mEnabled) {
-      mAuditLogEntries = new ArrayBlockingQueue<>(QUEUE_SIZE);
+      mAuditLogEntries = new LinkedBlockingQueue<>(QUEUE_SIZE);
     }
     mStopped = true;
   }