SpringBoot定时任务+自定义线程池实践
背景
在真实的Java开发环境中，我们经常会需要用到定时任务来帮助我们完成一些特殊的任务，比如我最近写的晚上11点定时拉取第三方的数据入库，晚上12点清理脏数据等等。
如果我们使用SpringBoot来开发，那么定时任务将会变得非常简单。SpringBoot默认已经帮我们封装好了相关定时任务的组件和配置，我们只需要在相应的地方加上@Schedule注解就可以实现定时任务。
启动定时任务
SpringBoot项目只需要在启动类上加上@EnableScheduling即可开启定时任务
@SpringBootApplication
@EnableScheduling
public class ScheduleTestApplication {
public static void main(String[] args) {
SpringApplication.run(ScheduleTestApplication.class, args);
}
}
创建定时任务
SpringBoot的Scheduler支持四种定时任务格式
fixedRate：固定速率执行，例如每3秒执行一次fixedDelay：固定延迟执行，例如距离上一次调用成功后3秒执行initialDelay：初始延迟任务，例如任务开启过3秒后再执行，之后以固定频率或者间隔执行cron：使用 Cron 表达式执行定时任务
以上在企业开发中经常用到的是cron表达式，可以说掌握了cron表达式，基本就掌握了SpringBoot的定时任务了。
使用cron表达式
@Component
public class ScheduleTask {
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
//每隔5秒执行一次该方法
@Scheduled(cron = "*/5 * * * * ?")
public void testScheduleTask() {
System.out.println("SpringBoot的定时任务" + Thread.currentThread().getName() + sdf.format(new Date()));
}
}
@Schedule默认线程池大小
其实@Schedule默认线程池大小为1，我们可以下面的实验得出这个结论。
@Component
public class ScheduleTask {
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
//固定2秒执行一次该方法
@Scheduled(fixedRate = 2000)
public void testScheduleTask() {
try{
Thread.sleep(6000);
System.out.println("SpringBoot的定时任务" + Thread.currentThread().getName() + sdf.format(new Date()));
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
结果每隔6秒执行一次，可以看到线程的名字为scheduleing-12021-01-12，表示都是用的同一个线程，默认@Schedule是开启一个线程。
一般情况下使用默认@Schedule没有问题，但是如果有多个定时任务，每个定时任务执行时间可能不短的情况下，会有可能出现定时任务一直没有机会执行的情况。
异步执行定时任务
给该方法加上@Async进行异步处理，看看会是什么效果～
@Component
@EnableAsync
public class ScheduleTask {
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
@Async
@Scheduled(fixedRate = 2000)
public void testScheduleTask() {
try{
Thread.sleep(6000);
System.out.println("SpringBoot的定时任务" + Thread.currentThread().getName() + sdf.format(new Date()));
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
可以看出线程的名字都是不一样的，然后每隔2秒的执行一次该方法，异步处理不受方法内的时间影响，并行执行。
手动实现自定义任务线程池
虽然可以用SpringBoot提供给我们的异步注解@Async处理，但是我们开发者也可以手动实现一个线程池，更好的配置和使用我们的异步处理。
@Component
public class AsyncScheduledTaskConfig {
@Bean
public Executor myAsync() {
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
//最大线程数
executor.setMaxPoolSize(100);
//核心线程数
executor.setCorePoolSize(10);
//任务队列的大小
executor.setQueueCapacity(10);
//线程前缀名
executor.setThreadNamePrefix("god-jiang-");
//线程存活时间
executor.setKeepAliveSeconds(30);
/**
* 拒绝处理策略
* CallerRunsPolicy()：交由调用方线程运行，比如 main 线程。
* AbortPolicy()：直接抛出异常。
* DiscardPolicy()：直接丢弃。
* DiscardOldestPolicy()：丢弃队列中最老的任务。
*/
executor.setRejectedExecutionHandler(new ThreadPoolExecutor.AbortPolicy());
//线程初始化
executor.initialize();
return executor;
}
}
使用自定义的线程池实现异步处理
@Component
@EnableAsync
public class ScheduleTask {
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
@Async("myAsync")
@Scheduled(fixedRate = 2000)
public void testScheduleTask() {
try{
Thread.sleep(6000);
System.out.println("SpringBoot的定时任务" + Thread.currentThread().getName() + sdf.format(new Date()));
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
当前线程名称已经被改成自定义god-jiang-的前缀！自定义线程池可以方便我们的项目更好的运行，同时也要设置前缀名字，方便出问题的时候我们可以排查是哪一个线程出的问题~~~
总结
以上就是我在企业开发中所用到的SpringBoot的@Schedule定时任务，并且搭配上我手动实现的线程池异步执行，基本可以满足绝大部分的开发需求。
这些仅为个人经验，希望能给大家一个参考，也希望大家多多支持脚本之家。
相关文章
这篇文章主要介绍了Java数组常见应用,结合实例形式详细分析了java数组的基本定义、创建、遍历、排序、查找等相关操作技巧与使用注意事项,需要的朋友可以参考下2020-02-02
Redis使用RedisTemplate模板类的常用操作方式
这篇文章主要介绍了Redis使用RedisTemplate模板类的常用操作方式，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2021-09-09
这篇文章主要介绍了java实现CSV 字段分割的相关资料,需要的朋友可以参考下2015-07-07
IntelliJ IDEA使用快捷键重命名项目、变量、文件等方法总结
今天小编就为大家分享一篇关于IntelliJ IDEA使用快捷键重命名项目、变量、文件等方法总结，小编觉得内容挺不错的，现在分享给大家，具有很好的参考价值，需要的朋友一起跟随小编来看看吧2018-10-10
事务消息是 RocketMQ 提供的一种高级消息类型,用于解决分布式场景下,本地数据库事务与消息发送之间的一致性问题,下面小编就来和大家聊聊SpringBoot集成RocketMQ事务消息的完整方法吧2025-10-10
Servlet指在服务器端执行的一段Java代码,可以接收用户的请求和返回给用户响应结果,下面这篇文章主要给大家介绍了关于JavaWeb.servlet生命周期的相关资料,需要的朋友可以参考下2022-10-10
Java中的String、StringBuilder、StringBuffer三者的区别详解
这篇文章主要介绍了Java中的String、StringBuilder、StringBuffer三者的区别详解,就是String,StringBuilder以及StringBuffer这三个类之间有什么区别呢,自己从网上搜索了一些资料,有所了解了之后在这里整理一下,便于大家观看,需要的朋友可以参考下2023-12-12
这篇文章主要介绍了Java 处理树形结构数据的过程，本文给大家分析具体实现过程，结合实例代码给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下2022-08-08
这篇文章主要介绍了Mybatis SqlSession详解,本文我们讲了如何创建SqlSession的几个步骤，最后我们获得一个DefaultSqlSession对象，里面包含了执行器Executor和配置对象Configuration，需要的朋友可以参考下2023-04-04
本文主要介绍了JWT令牌在Java中实现登录验证的方法,JWT是一种自我包含的、无状态的认证机制,可以用来在客户端和服务器之间传递安全可靠的信息,感兴趣的可以了解一下2024-12-12
最新评论