package com.iplatform.scheduler;
|
|
import com.iplatform.model.po.S_scheduler;
|
import com.iplatform.scheduler.support.MemoryScheduleEngine;
|
import com.walker.scheduler.ScheduleEngine;
|
|
import java.util.List;
|
|
/**
|
* 基于内存调度管理器实现，调度任务不存储数据库，仅在内存中。
|
* @author 时克英
|
* @date 2022-09-08
|
*/
|
public class MemorySchedulerManager extends PlatformSchedulerManager{
|
|
private MemoryScheduleEngine scheduleEngine;
|
|
public void setScheduleEngine(MemoryScheduleEngine scheduleEngine) {
|
this.scheduleEngine = scheduleEngine;
|
}
|
|
@Override
|
protected List<S_scheduler> acquireRunningList() {
|
logger.warn("内存实现的调度管理器: 无法在启动时初始化未完成任务! 系统停止则所有任务也终止，重启后无法自动重启任务，若要实现"
|
+ "自动重启需要配置为(DatabaseSchedulerManager)");
|
return null;
|
}
|
|
@Override
|
protected ScheduleEngine acquireScheduleEngine() {
|
if(this.scheduleEngine == null){
|
throw new IllegalArgumentException("请设置:MemoryScheduleEngine");
|
}
|
return this.scheduleEngine;
|
}
|
}
|
