Merge branch 'ver1.1' of http://192.168.0.204/yzg/yzg-util

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

@@ -89,11 +89,13 @@ public class YzgTimeout {
 
     private static void init() {
         synchronized (YzgTimeout.class) {
-            if (executorService == null) {
+            if (executorService != null) {
+                return;
+            }
+
             executorService = new ThreadPoolExecutor(1, 10, 1000,
                     TimeUnit.MILLISECONDS, new ArrayBlockingQueue<>(10));
-            }
-        }
+
             ThreadHelper.runThread(() -> {
                 while (true) {
                     runItem();
@@ -101,6 +103,7 @@ public class YzgTimeout {
                 }
             });
         }
+    }
 
     private static void runItem() {
         int size = queueInfos.size();