diff --git a/hippo4j-common/src/main/java/cn/hippo4j/common/toolkit/ContentUtil.java b/hippo4j-common/src/main/java/cn/hippo4j/common/toolkit/ContentUtil.java index 129b011a..68e19378 100644 --- a/hippo4j-common/src/main/java/cn/hippo4j/common/toolkit/ContentUtil.java +++ b/hippo4j-common/src/main/java/cn/hippo4j/common/toolkit/ContentUtil.java @@ -29,8 +29,6 @@ import java.util.Objects; public class ContentUtil { public static String getPoolContent(ThreadPoolParameter parameter) { - if (Objects.isNull(parameter)) - return null; ThreadPoolParameterInfo threadPoolParameterInfo = new ThreadPoolParameterInfo(); threadPoolParameterInfo.setTenantId(parameter.getTenantId()) .setItemId(parameter.getItemId()) diff --git a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/core/ClientWorker.java b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/core/ClientWorker.java index b083a162..60506c44 100644 --- a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/core/ClientWorker.java +++ b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/core/ClientWorker.java @@ -18,7 +18,6 @@ package cn.hippo4j.springboot.starter.core; import cn.hippo4j.common.model.ThreadPoolParameterInfo; -import cn.hippo4j.common.toolkit.CollectionUtil; import cn.hippo4j.common.toolkit.ContentUtil; import cn.hippo4j.common.toolkit.GroupKey; import cn.hippo4j.common.toolkit.IdUtil; @@ -103,21 +102,21 @@ public class ClientWorker { class LongPollingRunnable implements Runnable { - private boolean flag; + private boolean cacheMapInitEmptyFlag; private final CountDownLatch cacheCondition; - public LongPollingRunnable(boolean flag, CountDownLatch cacheCondition) { - this.flag = flag; + public LongPollingRunnable(boolean cacheMapInitEmptyFlag, CountDownLatch cacheCondition) { + this.cacheMapInitEmptyFlag = cacheMapInitEmptyFlag; this.cacheCondition = cacheCondition; } @Override @SneakyThrows public void run() { - if (flag) { + if (cacheMapInitEmptyFlag) { cacheCondition.await(); - flag = false; + cacheMapInitEmptyFlag = false; } serverHealthCheck.isHealthStatus(); List cacheDataList = new ArrayList();