From 371bc7b2de7d6c119122fb6d00d64b391a9cb4ef Mon Sep 17 00:00:00 2001 From: brido4125 Date: Thu, 31 Oct 2024 10:24:50 +0900 Subject: [PATCH] FIX: allNodes concurrency ploblem. --- src/main/java/net/spy/memcached/MemcachedConnection.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/src/main/java/net/spy/memcached/MemcachedConnection.java b/src/main/java/net/spy/memcached/MemcachedConnection.java index df4c0071c..72bf58384 100644 --- a/src/main/java/net/spy/memcached/MemcachedConnection.java +++ b/src/main/java/net/spy/memcached/MemcachedConnection.java @@ -44,6 +44,7 @@ import java.util.SortedMap; import java.util.TreeMap; import java.util.concurrent.ConcurrentLinkedQueue; +import java.util.concurrent.CopyOnWriteArrayList; import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicReference; @@ -145,7 +146,7 @@ public MemcachedConnection(String name, ConnectionFactory f, timeoutRatioThreshold = f.getTimeoutRatioThreshold(); timeoutDurationThreshold = f.getTimeoutDurationThreshold(); selector = Selector.open(); - List connections = new ArrayList<>(a.size()); + List connections = new CopyOnWriteArrayList<>(); for (SocketAddress sa : a) { connections.add(makeMemcachedNode(connName, sa)); }