如何在春季使用EnableScheduling批注在运行时重新启动计划的任务?

如何在春季使用EnableScheduling批注在运行时重新启动计划的任务?,第1张

如何在春季使用EnableScheduling批注在运行时重新启动计划的任务?
  1. 创建一个单例bean来注入
    TaskScheduler
    。这将持有的状态变量的所有
    ScheduledFuture
    小号,像
    private ScheduledFuture job1;
  2. 在部署时,从数据库加载所有计划数据并启动作业,并填充所有状态变量,例如
    job1
  3. 更改调度数据后,取消相应的
    Future
    (例如
    job1
    ),然后使用新的调度数据重新启动它。

此处的关键思想是在

Future
创建s时对其进行控制,以便将其保存在某些状态变量中,以便在调度数据中的某些内容发生更改时,可以将其取消。

这是工作代码:

applicationContext.xml

<task:annotation-driven /><task:scheduler id="infScheduler" pool-size="10"/>

单例bean,包含

Future
s

@Componentpublic class SchedulerServiceImpl implements SchedulerService {        private static final Logger logger = LoggerFactory.getLogger(SchedulerServiceImpl.class);        @Autowired        @Qualifier(value="infScheduler")        private TaskScheduler taskScheduler;        @Autowired        private MyService myService;        private ScheduledFuture job1;//for other jobs you can add new private state variables        //Call this on deployment from the ScheduleDataRepository and everytime when schedule data changes.        @Override        public synchronized void scheduleJob(int jobNr, long newRate) {//you are free to change/add new scheduling data, but suppose for now you only want to change the rate     if (jobNr == 1) {//instead of if/else you could use a map with all job data  if (job1 != null) {//job was already scheduled, we have to cancel it          job1.cancel(true);  }  //reschedule the same method with a new rate  job1 = taskScheduler.scheduleAtFixedRate(new ScheduledMethodRunnable(myService, "methodInMyServiceToReschedule"), newRate);     }        }}


欢迎分享,转载请注明来源:内存溢出

原文地址: http://outofmemory.cn/zaji/5430010.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2022-12-11
下一篇 2022-12-11

发表评论

登录后才能评论

评论列表(0条)

保存