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)); }