修复等待时间

yzg-util-mq/src/main/java/com/yanzuoguang/mq/dao/BeanDao.java

@@ -194,18 +194,24 @@ public class BeanDao {
     private void timeOut(Class<?> cls, String name, String message, Runnable runnable) {
         final Ref<Boolean> isRun = new Ref<>(false);
         ThreadHelper.runThread(() -> {
-            long timeMax = 1000;
-            int timeUnit = 10;
-            long start = System.currentTimeMillis();
-            do {
-                ThreadHelper.sleep(timeUnit);
-                long end = System.currentTimeMillis();
-                if (end - start > timeMax) {
-                    timeUnit = 1000;
-                    Log.error(cls, message + name + "超时,正在等待执行完成");
+            try {
+                long timeMax = 1000;
+                int timeUnit = 10;
+                long start = System.currentTimeMillis();
+                do {
+                    ThreadHelper.sleep(timeUnit);
+                    long end = System.currentTimeMillis();
+                    if (end - start > timeMax) {
+                        timeUnit = 1000;
+                        Log.error(cls, message + name + "超时,正在等待执行完成");
+                    }
                 }
+                while (!isRun.value);
+            } catch (Exception ex) {
+                ex.printStackTrace();
+            } finally {
+                Log.info(cls, message + name + "完成");
             }
-            while (!isRun.value);
         });
         runnable.run();
         isRun.value = true;