diff --git a/rec-admin/rec-admin-biz/src/main/java/cn/icanci/rec/admin/biz/thread/TriggerThread.java b/rec-admin/rec-admin-biz/src/main/java/cn/icanci/rec/admin/biz/thread/TriggerThread.java index 25ee1c70375c6f08b7b115ceacf1f515fc4e96ed..06e3105804a794409160481c9bec5fe7f7b0a16b 100644 --- a/rec-admin/rec-admin-biz/src/main/java/cn/icanci/rec/admin/biz/thread/TriggerThread.java +++ b/rec-admin/rec-admin-biz/src/main/java/cn/icanci/rec/admin/biz/thread/TriggerThread.java @@ -103,8 +103,8 @@ public class TriggerThread { // 进行消息通知触达线程 Thread triggerQueueThread = new Thread(() -> { - try { - while (true) { + while (true) { + try { LockSupport.parkNanos(TimeUnit.SECONDS.toNanos(3)); while (triggerQueue.size() > 0) { @@ -134,9 +134,9 @@ public class TriggerThread { } }); } + } catch (Throwable e) { + logger.warn("[TriggerThread][start][Throwable] error message:{}", e.getMessage()); } - } catch (Throwable e) { - logger.warn("[TriggerThread][start][Throwable] error message:{}", e.getMessage()); } }); triggerQueueThread.setDaemon(true);