tiennm99/zfoo
1
0
Fork 0
mirror of https://github.com/tiennm99/zfoo.git synced 2026-08-06 00:24:08 +00:00
Code Issues Packages Projects Releases Wiki Activity

perf[scheduler]:修复添加cron任务不执行

Browse Source
This commit is contained in:
meiwei
2023-08-24 14:24:19 +08:00
parent f0151eaa68
commit 3288db4ad8
1 changed files with 7 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
scheduler/src/main/java/com/zfoo/scheduler/manager/SchedulerBus.java
+7 -7
View File
@@ -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) {