From 216db96f1f172db7c771f937a230f3a01b9f00d0 Mon Sep 17 00:00:00 2001 From: wulang Date: Wed, 2 Nov 2022 13:48:15 +0800 Subject: [PATCH] feat:Field Rename --- .../java/cn/hippo4j/common/toolkit/ContentUtil.java | 2 -- .../hippo4j/springboot/starter/core/ClientWorker.java | 11 +++++------ 2 files changed, 5 insertions(+), 8 deletions(-) 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();