#23 replace LinkedList by ConcurrentLinkedQueue for idChunkQueue

yrodiere · Jun 6, 2016 · 4474125 · 4474125
1 parent e4c9f04
commit 4474125
Showing 1 changed file with 7 additions and 7 deletions.
diff --git a/us-address/src/main/java/io/github/mincongh/batch/IndexingContext.java b/us-address/src/main/java/io/github/mincongh/batch/IndexingContext.java
@@ -1,8 +1,7 @@
 package io.github.mincongh.batch;
 
 import java.io.Serializable;
-import java.util.LinkedList;
-import java.util.Queue;
+import java.util.concurrent.ConcurrentLinkedQueue;
 
 import javax.inject.Named;
 import javax.inject.Singleton;
@@ -13,22 +12,23 @@
 @Singleton
 public class IndexingContext {
 
-    private Queue<Serializable[]> idChunkQueue;
+    private ConcurrentLinkedQueue<Serializable[]> idChunkQueue;
+
     private IndexShardingStrategy indexShardingStrategy;
 
     public IndexingContext() {
-        this.idChunkQueue = new LinkedList<Serializable[]>();
+        this.idChunkQueue = new ConcurrentLinkedQueue<>();
     }
 
-    public synchronized void add(Serializable[] idArray) {
+    public void add(Serializable[] idArray) {
         idChunkQueue.add(idArray);
     }
 
-    public synchronized Serializable[] poll() {
+    public Serializable[] poll() {
         return idChunkQueue.poll();
     }
 
-    public synchronized int size() {
+    public int size() {
         return idChunkQueue.size();
     }