Fix readiness health check list mistake in parallel checking scenario (…

…#1309) Signed-off-by: crazyhzm <crazyhzm@apache.org>
sofastack · Apr 22, 2024 · e36ebc5 · e36ebc5
1 parent 2c4ea18
commit e36ebc5
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/...althcheck-sofa-boot/src/main/java/com/alipay/sofa/healthcheck/HealthCheckerProcessor.java b/...althcheck-sofa-boot/src/main/java/com/alipay/sofa/healthcheck/HealthCheckerProcessor.java
@@ -158,12 +158,12 @@ public boolean readinessHealthCheck(Map<String, Health> healthMap) {
         String checkComponentNames = readinessHealthCheckers.values().stream()
                 .map(HealthChecker::getComponentName).collect(Collectors.joining(","));
         logger.info("SOFABoot HealthChecker readiness check {} item: {}.",
-                healthCheckers.size(), checkComponentNames);
+                readinessHealthCheckers.size(), checkComponentNames);
         boolean result;
         if (healthCheckProperties.isHealthCheckParallelEnable()) {
-            CountDownLatch countDownLatch = new CountDownLatch(healthCheckers.size());
+            CountDownLatch countDownLatch = new CountDownLatch(readinessHealthCheckers.size());
             AtomicBoolean parallelResult = new AtomicBoolean(true);
-            healthCheckers.forEach((String key, HealthChecker value) -> healthCheckExecutor.executeTask(() -> {
+            readinessHealthCheckers.forEach((String key, HealthChecker value) -> healthCheckExecutor.executeTask(() -> {
                 try {
                     if (!doHealthCheck(key, value, false, healthMap, true, false)) {
                         parallelResult.set(false);