SpringBoot从入门到精通（三十五）使用@Scheduled实现多线程定时任务

2022-04-15 04:44:10

默认情况下，Spring Boot定时任务是按单线程方式执行的，也就是说，如果同一时刻有两个定时任务需要执行，那么只能在一个定时任务完成之后再执行下一个。如果只有一个定时任务，这样做肯定没问题；当定时任务增多时，如果一个任务被阻塞，则会导致其他任务无法正常执行。要解决这个问题，需要配置任务调度线程池。

一、实现多线程定时任务

下面通过示例演示Spring Boot 实现多线程定时任务。

1. 增加多线程配置类

在config目录下增加SchedulerConfig配置类，代码如下：

public class SchedulerConfig {
    @Bean
    public Executor taskScheduler() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(3);
        executor.setMaxPoolSize(10);
        executor.setQueueCapacity(3);
        executor.initialize();
        return executor;
    }
}

设置执行线程池为3，最大线程数为10。

2. 修改SchedulerTask定时任务

修改之前定义的SchedulerTask定时任务的类，在方法上增加@Async注解，使得后台任务能够异步执行，代码如下：

@EnableAsync // 开启异步事件的支持
@Component
public class SchedulerTask {
    private static final Logger logger = LoggerFactory.getLogger(SchedulerTask.class);
 
    @Async
   @Scheduled(cron="*/10 * * * * ?")
    public void taskCron() {
       SimpleDateFormat dateFormat = new SimpleDateFormat("HH:mm:ss");
       logger.info("SchedulerTask taskCron 现在时间： " + dateFormat.format(new Date()));
    }
 
    @Async
   @Scheduled(fixedRate = 5000)
    public void taskFixed() {
       SimpleDateFormat dateFormat = new SimpleDateFormat("HH:mm:ss");
       logger.info("SchedulerTask taskFixed 现在时间： " + dateFormat.format(new Date()));
    }
}

在上面的示例中，定时任务类SechedulerTask增加了@EnableAsync注解，开启了异步事件支持。同时，在定时方法上增加@Async注解，使任务能够异步执行，这样各个后台任务就不会阻塞。

二、测试验证

配置修改完成后，重新启动项目，查看后台任务的运行情况。如图10-2所示，全部的后台任务分成了多个线程执行，这样任务之间不会相互影响。

SpringBoot从入门到精通（三十五）使用@Scheduled实现多线程定时任务

通过后台日志可以看到，Spring Boot启动线程池负责调度执行后台任务，各个后台任务之间相对独立、互不影响。

最后

以上，我们就把Spring Boot实现多线程定时任务介绍完了。

码农公寓

一、实现多线程定时任务

二、测试验证

最后

相关文章