chore[comment]: scheduler comments

zfoo-project · Jan 20, 2024 · 7a008db · 7a008db
1 parent c263ed6
commit 7a008db
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/scheduler/src/main/java/com/zfoo/scheduler/manager/SchedulerBus.java b/scheduler/src/main/java/com/zfoo/scheduler/manager/SchedulerBus.java
@@ -141,8 +141,10 @@ private static void triggerPerSecond() {
                 // 到达触发时间，则执行runnable方法
                 try {
                     scheduler.getScheduler().invoke();
+                } catch (Exception e) {
+                    logger.error("scheduler invoke exception", e);
                 } catch (Throwable t) {
-                    logger.error("scheduler任务调度未知异常", t);
+                    logger.error("scheduler invoke error", t);
                 }
                 // 重新设置下一次的触发时间戳
                 triggerTimestamp = TimeUtils.nextTimestampByCronExpression(scheduler.getCronExpression(), timestampZonedDataTime);
@@ -175,7 +177,7 @@ public static ScheduledFuture<?> scheduleAtFixedRate(Runnable runnable, long per
      */
     public static ScheduledFuture<?> schedule(Runnable runnable, long delay, TimeUnit unit) {
 
-       return executor.schedule(ThreadUtils.safeRunnable(runnable), delay, unit);
+        return executor.schedule(ThreadUtils.safeRunnable(runnable), delay, unit);
     }
 
     /**