From 2d7ed439196927c18ecc90e1807a7bf0f115c1b4 Mon Sep 17 00:00:00 2001
From: icanci <qiang1.zhu@ly.com>
Date: Sun, 27 Nov 2022 14:26:45 +0800
Subject: [PATCH] codefix

---
 .../cn/icanci/rec/admin/biz/thread/TriggerThread.java     | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

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 25ee1c7..06e3105 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);
-- 
Gitee