This commit is contained in:
chuntaojun 2020-03-09 15:48:31 +08:00
parent 8466c347be
commit 8b848873e4

View File

@ -813,7 +813,11 @@ public class ServiceManager implements RecordListener<Service> {
@Override
public void run() {
// Parallel flow opening threshold
int parallelSize = 100;
serviceMap.forEach((namespace, stringServiceMap) -> {
Stream<Map.Entry<String, Service>> stream = null;
if (stringServiceMap.size() > parallelSize) {