欢迎大家来到IT世界,在知识的湖畔探索吧!
Timer的缺陷
在java中,Timer类可以实现定时任务,但Timer有两个致命缺陷,一是timer的任务是单线程运行的,如果前面的任务运行时间过长,会影响后面任务的运行,二是如果任务发生异常没有捕获,则后面的任务就不会执行了。
定时线程池
使用定时线程池则可以解决以上的问题
延迟任务
//创建两个线程的定时线程池
ScheduledExecutorService scheduledExecutorService = Executors.newScheduledThreadPool(2);
//任务延迟1S执行
scheduledExecutorService.schedule(() -> log.info("任务执行了11"), 1, TimeUnit.SECONDS);
scheduledExecutorService.schedule(() -> log.info("任务执行了22"), 1, TimeUnit.SECONDS);
欢迎大家来到IT世界,在知识的湖畔探索吧!
输出,可以看到有两个线程在执行任务
欢迎大家来到IT世界,在知识的湖畔探索吧!14:43:39.796 [pool-1-thread-2] INFO com.wkt.juc.ScheduleTest - 任务执行了22
14:43:39.796 [pool-1-thread-1] INFO com.wkt.juc.ScheduleTest - 任务执行了11
定时任务
scheduleAtFixedRate表示定时间隔执行,而跟前面任务的执行时间没关系(前提是前面任务的执行时间不能超过定时时间),比如间隔2S,那执行时间就是1S,3S,5S这样
//创建两个线程的定时线程池
ScheduledExecutorService scheduledExecutorService = Executors.newScheduledThreadPool(2);
//定时任务,初始延迟1S,每隔2S执行一次
scheduledExecutorService.scheduleAtFixedRate(() -> {
log.info("执行任务1");
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}, 1, 2, TimeUnit.SECONDS);
log.info("start");
scheduleWithFixedDelay是前面的任务执行完了后面的任务才会放入队列中,比如任务执行时间是1S,间隔2S,那执行时间是1S,4S,7S
欢迎大家来到IT世界,在知识的湖畔探索吧!//创建两个线程的定时线程池
ScheduledExecutorService scheduledExecutorService = Executors.newScheduledThreadPool(2);
//定时任务,初始延迟1S,前面任务执行完了再隔2S执行一次
scheduledExecutorService.scheduleWithFixedDelay(() -> {
log.info("执行任务1");
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}, 1, 2, TimeUnit.SECONDS);
log.info("start");
SpringBoot集成定时任务
第一步,开启定时任务
@EnableScheduling
public class ServerApp {
第二步,给定时任务加注解
fixedRate表示任务间隔N秒执行,fixedDelay表示前面的任务执行完了再间隔N秒执行
@Scheduled(fixedRate = 1000)
private void schedule() {
log.info("hello");
}
@Scheduled(fixedDelay = 1000)
private void schedule() {
log.info("hello");
}
Scheduled注解还支持cron表达式,记不住cron表达式也没关系,通过这个网站可以生成quartz/Cron/Crontab表达式在线生成工具-BeJSON.com
@Scheduled(cron = "0/1 * * * * ?")
private void testCron() {
log.info("hello");
}
需要注意的是,springboot的定时任务都是单线程的,也就是一个任务如果太耗时,会影响其他任务的执行,通过自定义线程池来实现多线程
@Configuration
public class ScheduleConfig implements SchedulingConfigurer {
@Override
public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
//根据业务设置核心线程数
taskRegistrar.setScheduler(Executors.newScheduledThreadPool(2));
}
}
免责声明:本站所有文章内容,图片,视频等均是来源于用户投稿和互联网及文摘转载整编而成,不代表本站观点,不承担相关法律责任。其著作权各归其原作者或其出版社所有。如发现本站有涉嫌抄袭侵权/违法违规的内容,侵犯到您的权益,请在线联系站长,一经查实,本站将立刻删除。 本文来自网络,若有侵权,请联系删除,如若转载,请注明出处:https://itzsg.com/22607.html