Skip to content

Commit 2170f0f

Browse files
authored
fix thread safety issue of ConsumerConfigurationListener (#15707)
1 parent 5c0bd7f commit 2170f0f

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

dubbo-registry/dubbo-registry-api/src/main/java/org/apache/dubbo/registry/client/ServiceDiscoveryRegistryDirectory.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -65,6 +65,7 @@
6565
import java.util.Set;
6666
import java.util.concurrent.ConcurrentHashMap;
6767
import java.util.concurrent.ConcurrentMap;
68+
import java.util.concurrent.CopyOnWriteArrayList;
6869
import java.util.stream.Collectors;
6970

7071
import static org.apache.dubbo.common.constants.CommonConstants.APPLICATION_KEY;
@@ -711,7 +712,7 @@ protected void notifyOverrides() {
711712
}
712713

713714
private static class ConsumerConfigurationListener extends AbstractConfiguratorListener {
714-
private final List<ServiceDiscoveryRegistryDirectory<?>> listeners = new ArrayList<>();
715+
private final List<ServiceDiscoveryRegistryDirectory<?>> listeners = new CopyOnWriteArrayList<>();
715716

716717
ConsumerConfigurationListener(ModuleModel moduleModel) {
717718
super(moduleModel);

0 commit comments

Comments
 (0)