今天用scheduled写定时任务的时候发现定时任务一秒重复执行一次,而我的cron表达式为 * 0/2 * * * * 。
在源码调试的过程中,发现是我的定时任务执行过程太短导致的。
于是我另外写了个简单的定时任务
|
1
2
3
4
5
6
7
8
|
@Component
public class TestJob {
@Scheduled(cron = "* 0/2 * * * *")
public void test() {
System.out.println("测试开始");
System.out.println("测试结束");
}
}
|
上述任务在启动之后一直执行。
然后我在任务后面加入线程睡眠1分钟。
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
|
@Component
public class TestJob {
@Scheduled(cron = "* 0/2 * * * *")
public void test() {
System.out.println("测试开始");
System.out.println("测试结束");
try {
Thread.sleep(60000);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("睡眠结束");
}
}
|
上述任务执行一次就没有再执行了。
所以我继续深入查看源码,发现问题在于CronSequenceGenerator.class的next方法。
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
|
public Date next(Date date) {
Calendar calendar = new GregorianCalendar();
calendar.setTimeZone(this.timeZone);
calendar.setTime(date);
//1.设置下次执行时间的毫秒为0,如上次任务执行过程不足1秒,则calendar的时间会被设置成上次任务的执行时间
calendar.set(14, 0);
long originalTimestamp = calendar.getTimeInMillis();
this.doNext(calendar, calendar.get(1));
//2.由于有上面一步,执行时间太短,会导致下述条件为true
if(calendar.getTimeInMillis() == originalTimestamp) {
//3.calendar在原来的时间上增加1秒
calendar.add(13, 1);
//CronSequenceGenerator的doNext算法从指定时间开始(包括指定时间)查找符合cron表达式规则下一个匹配的时间
//注意第一个匹配符是*,由于增加了1秒,依然符合cron="* 0/2 * * * *",所以下一个执行时间就是在原来的基础上增加了一秒
this.doNext(calendar, calendar.get(1));
}
return calendar.getTime();
}
|
请查看代码中的注释,由于任务执行时间太短了,代码会进入if语句,并设置执行时间在原来的基础上增加一秒。
但由于增加一秒后的时间戳依然符合cron表达式,于是在执行完代码后一秒,任务又开始执行了。
解决办法:
程序执行时间太短没有关系,只要cron表达式秒的匹配符不设置为*就可以了。
cron表达式可以设置为"0 0/2 * * * *",这样在执行到next方法中的doNext方法时就会发现时间增加1秒不符合cron表达式了,从而去寻找下一个合适的执行时间。
补充知识:SpringBoot 定时器/定时任务:在一个指定的周期时间内,执行某一项任务。
说多都是累,直接上代码:
实现方式有三种(可能还有更多的实现,这三种只是楼主目前所知道的):
1、静态定时器,无法修改周期
|
1
2
3
4
5
6
7
8
9
|
@Configuration("myScheduled")
@EnableScheduling
public class ScheduledDemo{
//每10秒执行一次
@Scheduled(cron="0/10 * * * * ?")
public void timmer(){
System.out.println("执行任务");
}
}
|
2、动态定时器
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
|
//通过setCron 方法修改 任务周期
@Component("myScheduled")
public class ScheduledDemo implements SchedulingConfigurer{
//默认的任务周期为 10秒
private String cron = "0/10 * * * * ?";
@Override
public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
// TODO Auto-generated method stub
taskRegistrar.addTriggerTask(new Runnable() {
@Override
public void run() {
// TODO Auto-generated method stub
System.out.println("执行任务");
}
}, new Trigger() {
@Override
public Date nextExecutionTime(TriggerContext triggerContext) {
return new CronTrigger(cron).nextExecutionTime(triggerContext);
}
});
}
public void setCron(String cron) {
this.cron = cron;
}
}
|
3、动态定时器:多线程定时任务执行,可以设置执行线程池数(默认一个线程)
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
|
@Component("myScheduled")
public class ScheduledImpl{
private ScheduledFuture<?> future;
@Autowired
private ThreadPoolTaskScheduler threadPoolTaskScheduler;
@Bean
public ThreadPoolTaskScheduler threadPoolTaskScheduler() {
return new ThreadPoolTaskScheduler();
}
@Override
public void setCron(final String cron) {
stopCron();
future = threadPoolTaskScheduler.schedule(new Runnable() {
@Override
public void run() {
// TODO Auto-generated method stub
System.out.println("执行任务");
}
}, new Trigger() {
@Override
public Date nextExecutionTime(TriggerContext triggerContext) {
if(cron==null || "".equals(cron)) {
return null;
}
CronTrigger cronTrigger = new CronTrigger(cron);
return cronTrigger.nextExecutionTime(triggerContext);
}
});
}
@Override
public void stopCron() {
if(future!=null) {
future.cancel(true);
}
}
}
|
cron 的参数说明,详细说明直接网上搜吧!
大概说明:秒 分 时 日 月 星期 年(可省略)
/ 后面表示周期
– 表示范围
星期一般用 ? ,为了防止和 日 混淆,如果星期有值,则日用 ?
“0/10 * * * * ?”表示每10秒
“0 0/10 * * * ?”表示每10分
以上这篇Springboot定时任务Scheduled重复执行操作就是小编分享给大家的全部内容了,希望能给大家一个参考,也希望大家多多支持快网idc。
原文链接:https://blog.csdn.net/has330338724/article/details/80812438
相关文章
- ASP.NET本地开发时常见的配置错误及解决方法? 2025-06-10
- ASP.NET自助建站系统的数据库备份与恢复操作指南 2025-06-10
- 个人网站服务器域名解析设置指南:从购买到绑定全流程 2025-06-10
- 个人网站搭建:如何挑选具有弹性扩展能力的服务器? 2025-06-10
- 个人服务器网站搭建:如何选择适合自己的建站程序或框架? 2025-06-10
- 2025-07-10 怎样使用阿里云的安全工具进行服务器漏洞扫描和修复?
- 2025-07-10 怎样使用命令行工具优化Linux云服务器的Ping性能?
- 2025-07-10 怎样使用Xshell连接华为云服务器,实现高效远程管理?
- 2025-07-10 怎样利用云服务器D盘搭建稳定、高效的网站托管环境?
- 2025-07-10 怎样使用阿里云的安全组功能来增强服务器防火墙的安全性?
快网idc优惠网
QQ交流群
-
2025-05-27 29
-
2025-06-04 19
-
2025-06-04 30
-
2025-05-29 43
-
2025-06-04 84

