gitee
/
roses
mirror of https://gitee.com/stylefeng/roses
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

【7.0.2】更新定时任务启动策略

pull/6/head
fengshuonan 2021-04-01 13:51:36 +08:00
parent 9228f60b07
commit f14ae6b1c2
1 changed files with 8 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
kernel-d-timer/timer-business/src/main/java/cn/stylefeng/roses/kernel/timer/modular/listener/TaskRunListener.java
View File

@ -30,6 +30,7 @@ import cn.stylefeng.roses.kernel.timer.api.enums.TimerJobStatusEnum;
import cn.stylefeng.roses.kernel.timer.modular.entity.SysTimers; import cn.stylefeng.roses.kernel.timer.modular.entity.SysTimers;
import cn.stylefeng.roses.kernel.timer.modular.param.SysTimersParam; import cn.stylefeng.roses.kernel.timer.modular.param.SysTimersParam;
import cn.stylefeng.roses.kernel.timer.modular.service.SysTimersService; import cn.stylefeng.roses.kernel.timer.modular.service.SysTimersService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.boot.context.event.ApplicationStartedEvent; import org.springframework.boot.context.event.ApplicationStartedEvent;
import org.springframework.context.ApplicationListener; import org.springframework.context.ApplicationListener;
import org.springframework.core.Ordered; import org.springframework.core.Ordered;
@ -42,6 +43,7 @@ import java.util.List;
* @author fengshuonan * @author fengshuonan
* @date 2021/1/12 20:40 * @date 2021/1/12 20:40
*/ */
@Slf4j
public class TaskRunListener implements ApplicationListener<ApplicationStartedEvent>, Ordered { public class TaskRunListener implements ApplicationListener<ApplicationStartedEvent>, Ordered {
@Override @Override
@ -60,7 +62,12 @@ public class TaskRunListener implements ApplicationListener<ApplicationStartedEv
// 添加定时任务到调度器 // 添加定时任务到调度器
for (SysTimers sysTimers : list) { for (SysTimers sysTimers : list) {
timerExeService.startTimer(String.valueOf(sysTimers.getTimerId()), sysTimers.getCron(), sysTimers.getActionClass()); try {
timerExeService.startTimer(String.valueOf(sysTimers.getTimerId()), sysTimers.getCron(), sysTimers.getActionClass());
} catch (Exception exception) {
// 遇到错误直接略过这个定时器（可能多个项目公用库）
log.error("定时器初始化遇到错误，略过该定时器！", exception);
}
} }
} }