升级新版本

yzg-util-base/src/main/java/com/yanzuoguang/util/helper/YzgTimeout.java

@@ -85,6 +85,10 @@ public class YzgTimeout {
     }
 
     private static void init() {
+        if (executorService != null) {
+            return;
+        }
+
         synchronized (YzgTimeout.class) {
             if (executorService != null) {
                 return;
@@ -95,8 +99,12 @@ public class YzgTimeout {
 
             ThreadHelper.runThread(() -> {
                 while (true) {
+                    try {
                         runItem();
-                    ThreadHelper.sleep(1000);
+                    } catch (Exception ex) {
+                        ex.printStackTrace();
+                    }
+                    ThreadHelper.sleep(200);
                 }
             });
         }
@@ -112,6 +120,9 @@ public class YzgTimeout {
             synchronized (queueInfos) {
                 poll = queueInfos.poll();
             }
+            if (poll == null) {
+                return;
+            }
             long end = System.currentTimeMillis();
             long time = end - poll.getStart();
             if (time > poll.getTimeMax()) {