用ConcurrentLinkedQueue来保存session实例，避免并发修改异常

lealone · Mar 23, 2016 · 995444a · 995444a
1 parent 620de51
commit 995444a
Showing 1 changed file with 3 additions and 7 deletions.
diff --git a/lealone-net/src/main/java/org/lealone/net/CommandHandler.java b/lealone-net/src/main/java/org/lealone/net/CommandHandler.java
@@ -71,20 +71,16 @@ public static void removeConnection(AsyncConnection c) {
         c.close();
     }
 
-    private final LinkedList<Integer> sessions = new LinkedList<>();
+    private final ConcurrentLinkedQueue<Integer> sessions = new ConcurrentLinkedQueue<>();
     private final Semaphore haveWork = new Semaphore(1);
     private boolean stop;
 
     void addSessionId(Integer sessionId) {
-        synchronized (sessions) {
-            sessions.add(sessionId);
-        }
+        sessions.add(sessionId);
     }
 
     void removeSessionId(Integer sessionId) {
-        synchronized (sessions) {
-            sessions.remove(sessionId);
-        }
+        sessions.remove(sessionId);
     }
 
     public CommandHandler(int id) {