From d899556bfd890bd22b6594c740baa89c573ce02a Mon Sep 17 00:00:00 2001
From: v-zhangjc9 <v-zhangjc9.gd@chinatelecom.cn>
Date: Fri, 26 Apr 2024 11:53:04 +0800
Subject: [PATCH] =?UTF-8?q?refactor(launcher):=20=E5=A2=9E=E5=8A=A0Clear?=
 =?UTF-8?q?=20hodler=E6=97=B6=E7=9A=84=E6=97=A5=E5=BF=97?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../service/launcher/compaction/service/CompactionService.java  | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/service-launcher/src/main/java/com/lanyuanxiaoyao/service/launcher/compaction/service/CompactionService.java b/service-launcher/src/main/java/com/lanyuanxiaoyao/service/launcher/compaction/service/CompactionService.java
index 8dfd7c1..ced75ea 100644
--- a/service-launcher/src/main/java/com/lanyuanxiaoyao/service/launcher/compaction/service/CompactionService.java
+++ b/service-launcher/src/main/java/com/lanyuanxiaoyao/service/launcher/compaction/service/CompactionService.java
@@ -229,9 +229,11 @@ public class CompactionService {
         if (holder.isEmpty()) {
             return;
         }
+        logger.info("Clear holder, size: {}", holder.size());
         // 等待半分钟
         ThreadUtil.safeSleep(Constants.HALF_MINUTE);
         for (QueueItem<ScheduleJob> item : holder) {
+            logger.info("Push task to pre {}", item);
             QueueUtil.add(discoveryClient, this.mapper, Constants.COMPACTION_QUEUE_PRE, item);
         }
         holder.clear();