diff --git a/src/main/java/org/redkale/schedule/spi/ScheduleManagerService.java b/src/main/java/org/redkale/schedule/spi/ScheduleManagerService.java index 980ccbf77..59d0dca6e 100644 --- a/src/main/java/org/redkale/schedule/spi/ScheduleManagerService.java +++ b/src/main/java/org/redkale/schedule/spi/ScheduleManagerService.java @@ -162,7 +162,7 @@ public class ScheduleManagerService implements ScheduleManager, Service { } while ((clazz = clazz.getSuperclass()) != Object.class); //开始执行定时任务 if (enabled && !tasks.isEmpty()) { - tasks.forEach((name, task) -> task.start()); + tasks.forEach((name, task) -> task.init()); refTaskMap.put(ref, new ArrayList<>(tasks.values())); } } finally { @@ -360,6 +360,10 @@ public class ScheduleManagerService implements ScheduleManager, Service { this.event = method.getParameterCount() == 0 ? null : new ScheduleEvent(); } + public void init() { + start(); + } + public abstract void start(); public void stop() {