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 item : holder) { + logger.info("Push task to pre {}", item); QueueUtil.add(discoveryClient, this.mapper, Constants.COMPACTION_QUEUE_PRE, item); } holder.clear();