diff --git a/naming/src/main/java/com/alibaba/nacos/naming/core/ServiceManager.java b/naming/src/main/java/com/alibaba/nacos/naming/core/ServiceManager.java index 0bc0bf323..f406710c4 100644 --- a/naming/src/main/java/com/alibaba/nacos/naming/core/ServiceManager.java +++ b/naming/src/main/java/com/alibaba/nacos/naming/core/ServiceManager.java @@ -813,7 +813,11 @@ public class ServiceManager implements RecordListener { @Override public void run() { + + // Parallel flow opening threshold + int parallelSize = 100; + serviceMap.forEach((namespace, stringServiceMap) -> { Stream> stream = null; if (stringServiceMap.size() > parallelSize) {