fix: adding a message handler while handling a message does not cause…

… concurrency exceptions
AlmasB · May 6, 2023 · d44c647 · d44c647
1 parent 557035e
commit d44c647
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/fxgl-io/src/main/java/com/almasb/fxgl/net/Connection.java b/fxgl-io/src/main/java/com/almasb/fxgl/net/Connection.java
@@ -16,6 +16,7 @@
 import java.util.List;
 import java.util.concurrent.ArrayBlockingQueue;
 import java.util.concurrent.BlockingQueue;
+import java.util.concurrent.CopyOnWriteArrayList;
 
 /**
  * @author Almas Baimagambetov ([email protected])
@@ -30,8 +31,8 @@ public abstract class Connection<T> {
 
     private PropertyMap localSessionData = new PropertyMap();
 
-    protected final List<MessageHandler<T>> messageHandlers = new ArrayList<>();
-    protected final List<MessageHandler<T>> messageHandlersFX = new ArrayList<>();
+    protected final List<MessageHandler<T>> messageHandlers = new CopyOnWriteArrayList<>();
+    protected final List<MessageHandler<T>> messageHandlersFX = new CopyOnWriteArrayList<>();
 
     protected BlockingQueue<T> messageQueue = new ArrayBlockingQueue<>(100);