Use CopyOnWriteArraySet for ConnectionGroup#connectionSet to avoid it…

…erator fast-fail (alibaba#2559)
Zhang-0952 · Feb 7, 2022 · ee5c4c9 · ee5c4c9
1 parent 3425546
commit ee5c4c9
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...ult/src/main/java/com/alibaba/csp/sentinel/cluster/server/connection/ConnectionGroup.java b/...ult/src/main/java/com/alibaba/csp/sentinel/cluster/server/connection/ConnectionGroup.java
@@ -19,6 +19,7 @@
 import java.util.HashSet;
 import java.util.Set;
 import java.util.concurrent.ConcurrentSkipListSet;
+import java.util.concurrent.CopyOnWriteArraySet;
 import java.util.concurrent.atomic.AtomicInteger;
 
 import com.alibaba.csp.sentinel.cluster.server.ServerConstants;
@@ -34,7 +35,7 @@ public class ConnectionGroup {
 
     private final String namespace;
 
-    private final Set<ConnectionDescriptor> connectionSet = Collections.synchronizedSet(new HashSet<ConnectionDescriptor>());
+    private final Set<ConnectionDescriptor> connectionSet = new CopyOnWriteArraySet<>();
     private final AtomicInteger connectedCount = new AtomicInteger();
 
     public ConnectionGroup(String namespace) {