OAK-11213 : removed usage of Guava Queues.newConcurrentLinkedQueue

fabriziofortino · Oct 22, 2024 · 487699a · 487699a
1 parent 2031e44
commit 487699a
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 5 deletions.
diff --git a/oak-segment-tar/src/main/java/org/apache/jackrabbit/oak/segment/CommitsTracker.java b/oak-segment-tar/src/main/java/org/apache/jackrabbit/oak/segment/CommitsTracker.java
@@ -18,14 +18,13 @@
  */
 package org.apache.jackrabbit.oak.segment;
 
-import static org.apache.jackrabbit.guava.common.collect.Queues.newConcurrentLinkedQueue;
-
 import java.lang.ref.WeakReference;
 import java.util.HashMap;
 import java.util.Iterator;
 import java.util.Map;
 import java.util.Queue;
 import java.util.concurrent.ConcurrentHashMap;
+import java.util.concurrent.ConcurrentLinkedQueue;
 import java.util.concurrent.ConcurrentMap;
 import java.util.function.Supplier;
 
@@ -53,7 +52,7 @@ class CommitsTracker {
     private final String[] threadGroups;
     private final int otherWritersLimit;
     private final ConcurrentMap<String, Commit> queuedWritersMap;
-    private final Queue<Commit> commits = newConcurrentLinkedQueue();
+    private final Queue<Commit> commits = new ConcurrentLinkedQueue<>();
 
     /*
      * Read access via getCurrentWriter() happens usually on a separate thread, thus volatile

diff --git a/...ment-tar/src/main/java/org/apache/jackrabbit/oak/segment/tool/iotrace/IOTraceMonitor.java b/...ment-tar/src/main/java/org/apache/jackrabbit/oak/segment/tool/iotrace/IOTraceMonitor.java
@@ -18,7 +18,6 @@
 
 package org.apache.jackrabbit.oak.segment.tool.iotrace;
 
-import static org.apache.jackrabbit.guava.common.collect.Queues.newConcurrentLinkedQueue;
 import static java.lang.String.join;
 
 import java.io.File;
@@ -53,7 +52,7 @@ public class IOTraceMonitor extends IOMonitorAdapter implements Flushable {
     private final Lock ioLock = new ReentrantLock();
 
     @NotNull
-    private final ConcurrentLinkedQueue<IOEvent> ioEvents = newConcurrentLinkedQueue();
+    private final ConcurrentLinkedQueue<IOEvent> ioEvents = new ConcurrentLinkedQueue<>();
 
     /**
      * Create a new instance writing to {@code traceWriter} with additional context fields.