From 322b9b8aa17b865ff933fa76c004d0105127bb71 Mon Sep 17 00:00:00 2001 From: "chen.ma" Date: Sat, 5 Nov 2022 01:21:44 +0800 Subject: [PATCH] Code optimization and logic refactoring --- .../main/java/cn/hippo4j/config/notify/DefaultPublisher.java | 4 ++-- .../java/cn/hippo4j/config/service/LongPollingService.java | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/hippo4j-server/hippo4j-config/src/main/java/cn/hippo4j/config/notify/DefaultPublisher.java b/hippo4j-server/hippo4j-config/src/main/java/cn/hippo4j/config/notify/DefaultPublisher.java index c43fb591..39612b11 100644 --- a/hippo4j-server/hippo4j-config/src/main/java/cn/hippo4j/config/notify/DefaultPublisher.java +++ b/hippo4j-server/hippo4j-config/src/main/java/cn/hippo4j/config/notify/DefaultPublisher.java @@ -79,7 +79,7 @@ public class DefaultPublisher extends Thread implements EventPublisher { private void openEventHandler() { try { int waitTimes = 60; - for (; ; ) { + for (;;) { if (shutdown || hasSubscriber() || waitTimes <= 0) { break; } @@ -90,7 +90,7 @@ public class DefaultPublisher extends Thread implements EventPublisher { } waitTimes--; } - for (; ; ) { + for (;;) { if (shutdown) { break; } diff --git a/hippo4j-server/hippo4j-config/src/main/java/cn/hippo4j/config/service/LongPollingService.java b/hippo4j-server/hippo4j-config/src/main/java/cn/hippo4j/config/service/LongPollingService.java index 7a96832e..a485048c 100644 --- a/hippo4j-server/hippo4j-config/src/main/java/cn/hippo4j/config/service/LongPollingService.java +++ b/hippo4j-server/hippo4j-config/src/main/java/cn/hippo4j/config/service/LongPollingService.java @@ -105,7 +105,7 @@ public class LongPollingService { @Override public void run() { try { - for (Iterator iter = allSubs.iterator(); iter.hasNext(); ) { + for (Iterator iter = allSubs.iterator(); iter.hasNext();) { ClientLongPolling clientSub = iter.next(); String identity = groupKey + GROUP_KEY_DELIMITER + identify; List parseMapForFilter = CollectionUtil.newArrayList(identity);