Spring定时任务-多线程配置

目前常见的定时任务框架有Quarts、Elastic-Job、xxl-job等。但其实SpringBoot也有一个内置的定时任务框架，不需要引入额外的Jar，使用Spring自带的注解就可以，比Quarts更轻量。这里分享给大家，有机会不妨一试。

注意：以下所有代码基于SpringBoot2.3。

简单使用步骤：

在SpringBoot启动类上加上@EnableScheduling注解。代码参考：

@SpringBootApplication
@EnableTransactionManagement
@EnableScheduling
@MapperScan("com.purvar.mapper")
public class SccwebApplication {public static void main(String[] args) {SpringApplication.run(SccwebApplication.class, args);}}

在定时任务方法上加上@Scheduled注解并指定cron表达式。代码参考：

@Service
public class ScheduleService{@Scheduled(cron = "* * * * * ?")public void task1() throws Exception {System.out.println("task1 start:" + new SimpleDateFormat("yyyy-MM-dd hh:mm:ss").format(new Date()));TimeUnit.SECONDS.sleep(3);System.out.println("task1 end:" + new SimpleDateFormat("yyyy-MM-dd hh:mm:ss").format(new Date()));}@Scheduled(cron = "* * * * * ?")public void task2() throws Exception {System.out.println("task2 start:" + new SimpleDateFormat("yyyy-MM-dd hh:mm:ss").format(new Date()));}
}

到这里，定时任务已经配置好了。上面案例代码中的任务方法task1和task2任务方法会按配置定时执行了。是不是比quarts简单多了？接下来，还有一些进阶的使用技巧分享给大家。

对于想要对所有定时任务做统一管理的，可以使用一个单独的配置类来配置所有的定时任务方法执行周期。类似quarts的配置文件。
Spring定时任务默认所有任务方法都是单线程执行的。强烈建议改成多线程。
Spring定时任务还支持同一个任务方法多线程执行。但使用前建议先做好并发控制。

拿上文中案例代码里面的task1和task2来说，这2个定时任务方法配置的都是每秒执行1次，但由于Spring默认是所有任务方法单线程执行，task2会等task1执行完了再执行。第一个任务如果执行需要3秒，那第2个要等到第3秒之后才会执行。执行效果见日志。

task1 start:2021-10-10 10:26:42
task1 end:2021-10-10 10:26:45
task2 start:2021-10-10 10:26:45（ps：3秒后才执行）
task1 start:2021-10-10 10:26:46
task1 end:2021-10-10 10:26:49
task2 start:2021-10-10 10:26:49
task1 start:2021-10-10 10:26:50
task1 end:2021-10-10 10:26:53
task2 start:2021-10-10 10:26:53

不同任务方法多线程配置步骤：

新建一个定时任务配置类，实现SchedulingConfigurer接口，加上@Configuration和
@EnableScheduling注解
覆盖configureTasks方法，并在方法体中配置线程池，线程池数量最好大于定时任务数量
在类中统一配置所有定时任务方法的调度规则。代码案例如下：：

/*** 所有的定时任务都放这里,方便管理<br>* 如果想把所有定时任务全部关闭总开关 把@Configuration注释<br>* 如果想把某个定时任务全关闭 把对应方法上的@Scheduled注释<br>* @author namelessmyth* @since 2021-10-10*/
@Configuration
@EnableScheduling
@EnableAsync
public class ScheduleConfig implements SchedulingConfigurer {/** 调用service的方法，不要在这里写业务逻辑*/@Autowiredprivate FixService fixService;/*** 配置线程池,确保不同的任务方法使用不同的线程执行.<br>* Spring默认是单线程执行所有定时任务方法<br>* <font color="red">如果定时任务的总数量超过了线程池的大小，请记得及时调整</font><br>* <font color="blue">@EnableAsync和@Async用于使同一个任务方法变成多线程处理，使用前需要控制好并发问题</font><br>* @param taskRegistrar*/public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {taskRegistrar.setScheduler(Executors.newScheduledThreadPool(5));}@Scheduled(cron = "* * * * * ?")@Asyncpublic void task1() throws Exception {System.out.println("task1 start:" + new SimpleDateFormat("yyyy-MM-dd hh:mm:ss").format(new Date()));TimeUnit.SECONDS.sleep(3);System.out.println("task1 end:" + new SimpleDateFormat("yyyy-MM-dd hh:mm:ss").format(new Date()));}@Scheduled(cron = "* * * * * ?")public void task2() throws Exception {System.out.println("task2 start:" + new SimpleDateFormat("yyyy-MM-dd hh:mm:ss").format(new Date()));}@Scheduled(cron = "0 30 1 * * ?")public void fixImesFlagJob() throws Exception {fixService.fixImesFlag(null);}}

修改之后的执行日志，可以看出task2已经不在等task1执行完了再执行了：

task1 start:2021-10-10 10:23:47
task2 start:2021-10-10 10:23:47
task2 start:2021-10-10 10:23:48
task2 start:2021-10-10 10:23:49
task2 start:2021-10-10 10:23:50
task1 end:2021-10-10 10:23:50
task1 start:2021-10-10 10:23:51
task2 start:2021-10-10 10:23:51
task2 start:2021-10-10 10:23:52
task2 start:2021-10-10 10:23:53
task1 end:2021-10-10 10:23:54
task2 start:2021-10-10 10:23:54
task2 start:2021-10-10 10:23:55
task1 start:2021-10-10 10:23:55
task2 start:2021-10-10 10:23:56

同一个定时任务方法异步执行配置步骤：

在@EnableScheduling注解下方加上@EnableAsync注解
在要异步执行的定时任务方法上加上@Async注解。

配置了异步之后，如果task1配置的是每隔1秒执行1次。那不管task1到1秒之后有没有执行结束，Spring都会启动一个新线程来再次执行task1的方法体。所以在使用这个配置时一定要控制好并发。这里有一些异步定时任务的使用建议供大家参考。

定时任务在执行时查询状态为“待处理”的数据。
在开始真正的业务处理前，可以先将数据改成处理中。（这一步可以做下并发控制）
然后执行业务处理。
业务做完把数据状态改成“处理完成”。

按照上述步骤处理之后，即使第1个线程到达时间没有处理完，那下一个线程启动后也不会查询到同一条待处理数据了。这样就实现了定时任务多线程执行同一个任务方法。

Spring定时任务-多线程配置相关推荐

Spring @Scheduled 多线程配置
Spring @Scheduled 多线程配置环境 SpringBoot 2.0.2.RELEASE JDK8 两种方式实现 1.@Scheduled+@Async 测试代码: @SpringBoo ...
spring定时任务时间配置cron表达式
1.Spring quartz 1.1 单纯针对时间的设置规则 org.springframework.scheduling.quartz.CronTriggerBean允许你更精确地控制任务的运行时 ...
Spring定时任务的配置
spring的定时任务配置分为三个步骤: 1.定义任务 2.任务执行策略配置 3.启动任务 1.定义任务  <bean id="test ...
spring定时任务的配置使用
spring的定时任务配置分为三个步骤: 1.定义任务 2.任务执行策略配置 3.启动任务 1.定义任务  <bean id="test ...
Spring定时任务多线程
单线程 1)在Spring.xml中开启定时器的功能 <?xml version="1.0" encoding="UTF-8"?><beans ...
Spring定时任务@scheduled多线程的使用（@Async注解）
1.开篇在Spring定时任务@Scheduled注解使用方式浅窥这篇文章里面提及过,spring的定时任务默认是单线程的,他在某些场景下会造成堵塞,那么如果我们想让每一个任务都起一条线程去执行呢? ...
spring 定时任务多任务并行执行，多任务多线程单任务单线程执行实现细节
前提:spring 定时任务,默认是多任务单线程执行,也就是串行执行的当前需求: 1. 多任务多线程执行(不同的定时任务并行执行) 2.同一个定时任务单线程执行(保证一个定时任务A在执行完成前,A的 ...
Spring定时任务@Scheduled注解使用配置方式（cron表达式、fixedRate和fixedDelay）
Spring定时任务@Scheduled注解使用配置方式(cron表达式.fixedRate和fixedDelay) 序言: 个人推荐一个很方便的在线Cron生成器(网页版):https://qqe2 ...
Spring Task定时任务的配置和使用详解
spring中使用定时任务 1.基于xml配置文件使用定时任务首先配置spring开启定时任务 <beans xmlns="http://www.springframework.or ...

Spring定时任务-多线程配置

Spring定时任务-多线程配置相关推荐

最新文章

热门文章