From 3288db4ad8f7c164c18e88a2c4acae2b7e7c8cbd Mon Sep 17 00:00:00 2001
From: meiwei <309921330@qq.com>
Date: Thu, 24 Aug 2023 14:24:19 +0800
Subject: [PATCH] =?UTF-8?q?perf[scheduler]:=E4=BF=AE=E5=A4=8D=E6=B7=BB?=
 =?UTF-8?q?=E5=8A=A0cron=E4=BB=BB=E5=8A=A1=E4=B8=8D=E6=89=A7=E8=A1=8C?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/zfoo/scheduler/manager/SchedulerBus.java   | 14 +++++++-------
 1 file changed, 7 insertions(+), 7 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
index a36966d5..4f8b707c 100644
--- a/scheduler/src/main/java/com/zfoo/scheduler/manager/SchedulerBus.java
+++ b/scheduler/src/main/java/com/zfoo/scheduler/manager/SchedulerBus.java
@@ -166,24 +166,24 @@ public abstract class SchedulerBus {
     /**
      * 不断执行的周期循环任务
      */
-    public static ScheduledFuture<?> scheduleAtFixedRate(Runnable runnable, long period, TimeUnit unit) {
+    public static void scheduleAtFixedRate(Runnable runnable, long period, TimeUnit unit) {
         if (SchedulerContext.isStop()) {
-            return null;
+            return;
         }
 
-        return executor.scheduleAtFixedRate(SafeRunnable.valueOf(runnable), 0, period, unit);
+        executor.scheduleAtFixedRate(SafeRunnable.valueOf(runnable), 0, period, unit);
     }
 
 
     /**
      * 固定延迟执行的任务
      */
-    public static ScheduledFuture<?> schedule(Runnable runnable, long delay, TimeUnit unit) {
+    public static void schedule(Runnable runnable, long delay, TimeUnit unit) {
         if (SchedulerContext.isStop()) {
-            return null;
+            return;
         }
 
-       return executor.schedule(SafeRunnable.valueOf(runnable), delay, unit);
+        executor.schedule(SafeRunnable.valueOf(runnable), delay, unit);
     }
 
     /**
@@ -194,7 +194,7 @@ public abstract class SchedulerBus {
             return;
         }
 
-        schedulerDefList.add(SchedulerDefinition.valueOf(cron, runnable));
+        registerScheduler(SchedulerDefinition.valueOf(cron, runnable));
     }
 
     public static Executor threadExecutor(long currentThreadId) {