默认情况下 Spring 是单线程来跑所有的定时任务,即任务是串行的,任务 B 必须等到任务 A 执行完成后才能得到执行。
```java
@Scheduled(cron = "10 0/1 * * * ?")
public void timerJobA() {
log.info("[timerJobA]: {}", Thread.currentThread().getName());
try {
//每1min10s跑一次,一次需要30s跑完
Thread.sleep(30 * 1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
@Scheduled(cron = "20 0/1 * * * ?")
public void timerJobB() {
//每1min20s跑一次
log.info("[timerJobB]: {}", Thread.currentThread().getName());
}
```
```
打印如下日志,可以看到是同一个线程在跑两个定时任务。
任务 B 应该在 22:23:20、22:24:20、22:25:20 这些时间点上跑,但实际不是,
因为它要等任务 A 跑完才能开始跑。
2023-12-15 22:23:10 ...: [timerJobA]: scheduling-1
2023-12-15 22:23:40 ...: [timerJobB]: scheduling-1
2023-12-15 22:24:10 ...: [timerJobA]: scheduling-1
2023-12-15 22:24:40 ...: [timerJobB]: scheduling-1
2023-12-15 22:25:10 ...: [timerJobA]: scheduling-1
2023-12-15 22:25:40 ...: [timerJobB]: scheduling-1
```
<br/>
如果想让定时任务并行执行,可以配置线程池,可以选择下面两种配置方式之一。
**1. 代码中配置线程池**
```java
@Configuration
public class ScheduleConfig implements SchedulingConfigurer {
@Override
public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
taskRegistrar.setScheduler(Executors.newScheduledThreadPool(10));
}
}
```
**2. 配置文件中配置**
```yml
###任务调度线程池
#任务调度线程池大小,默认 1
spring.task.scheduling.pool.size: 5
#true-线程池关闭时等待所有任务完成,默认false
spring.task.scheduling.shutdown.await-termination: true
#调度线程关闭前最大等待时间,确保最后一定关闭
spring.task.scheduling.shutdown.await-termination-period: 20s
###任务执行线程池配置
#true-允许核心线程超时。这样可以动态增加和缩小线程池
spring.task.execution.pool.allow-core-thread-timeout: true
#核心线程池大小,默认 8
spring.task.execution.pool.core-size: 10
#线程空闲等待时间 默认 60s
spring.task.execution.pool.keep-alive: 60s
#线程池最大数
spring.task.execution.pool.max-size: 20
#线程池队列容量大小
spring.task.execution.pool.queue-capacity: 10
#true-线程池关闭时等待所有任务完成
spring.task.execution.shutdown.await-termination: true
#执行线程关闭前最大等待时间,确保最后一定关闭
spring.task.execution.shutdown.await-termination-period: 20s
```
```
配置线程池后控制台打印如下日志,可以看到任务 B 不必等到任务 A 跑完才开始跑了,
做到了任务的并行执行。
2023-12-16 14:16:10 ...: [timerJobA]: scheduling-2
2023-12-16 14:16:20 ...: [timerJobB]: scheduling-3
2023-12-16 14:17:10 ...: [timerJobA]: scheduling-2
2023-12-16 14:17:20 ...: [timerJobB]: scheduling-1
2023-12-16 14:18:10 ...: [timerJobA]: scheduling-2
2023-12-16 14:18:20 ...: [timerJobB]: scheduling-1
```
- Spring
- Spring是什么
- Spring与EJB对比
- Spring的组成
- 首个Spring程序
- IoC控制反转
- 什么是IoC
- IoC编程
- 依赖注入方式
- 不同变量注入
- AOP面向切面编程
- AOP思想
- AOP实现原理
- AOP关键术语
- AOP编程
- 5种增强方式
- 切入点规则
- 自动装配
- Spring注解开发
- Bean注解
- AOP注解
- 完全注解
- 配置文件拆分
- SpringBean
- Bean常用属性
- Bean作用域
- Bean生命周期
- SpringBoot
- SpringBoot是什么
- 项目创建
- 配置文件
- 配置类型
- 读取配置
- 占位符
- 多环境配置
- 配置优先级
- 更改配置文件
- 自定义IoC容器
- 常用组件
- ApplicationContextAware
- CommandLineRunner
- Boot[Web]
- 引入模板引擎
- 静态资源访问
- 指定首页
- JSP支持
- 注册拦截器
- 注册Servlet组件
- 注册Servlet
- 注册过滤器
- 注册监听器
- 拦截器与过滤器区别
- 文件上传
- 文件下载
- 变更服务器
- Controller层封装
- HttpServletRequest
- 获取请求行
- 获取请求头
- 获取请求体
- Boot[自动配置]
- 自动配置是什么
- 自动配置报告
- 关闭自动配置
- 条件注解
- Boot[场景启动器]
- 场景启动器是什么
- 自定义场景启动器
- Boot[日志]
- 日志框架
- 日志级别
- 日志配置
- 配置文件
- 切换日志
- Boot[邮件任务]
- Boot[定时任务]
- cron表达式
- 起步
- 任务并行
- 注解Scheduled参数
- Boot[异步任务]
- 起步
- 注意事项与原理
- 自定义线程池
- Boot[缓存]
- JSR107缓存技术
- Spring缓存抽象
- 缓存注解
- SpEL表达式
- 起步
- 自定义key生成器
- 工作原理
- Boot[Redis]
- 起步
- 序列化机制
- Boot[Jdbc]
- 起步
- 两个模板类
- JdbcTemplate
- 增删改
- 查询
- NamedParameterJdbcTemplate
- 增删改
- 查询
- 自定义JdbcTemplate
- Boot[JPA]
- SpringDataJPA是什么
- 与JPA、Hibernate的关系
- 起步
- SpringDataJPA原理
- 查询方式
- 方法命名规则查询
- 限制查询结果查询
- 注解Query查询
- 命名参数查询
- SpEL表达式查询
- 原生查询
- 更新与删除
- 查询指定字段
- Specification动态查询
- 分页查询与排序
- 多表查询
- 一对一查询
- 一对多查询
- 多对多查询
- Specification查询
- Query注解查询
- 主键策略
- 单独主键
- 联合主键
- 级联操作
- 加载规则
- 审计功能
- 常用注解
- 避坑指南
- Boot[JSR303]
- JSR303是什么
- 常用约束
- 起步
- 简单校验
- 嵌套校验
- 分组校验
- 自定义约束注解
- 自定义校验工具
- Spring事务
- 事务的作用
- 起步
- 事务参数
- SpringDoc文档
- SpringDoc是什么
- 起步
- 自定义配置
- 常用Doc注解
- JSR303文档
- knife4j文档
- 常用配置
- Boot[RabbitMQ]
- 起步
- Fanout交换机类型
- Direct交换机类型
- Topic交换机类型
- 延迟队列插件
- RabbitListener监听方法
- JWT认证
- 认证流程
- 起步
- 密码加密
- JWT认证实现