Spring Boot多个定时任务阻塞问题的解决方法
程序员文章站
2022-06-15 11:47:50
目录前言1、重写schedulingconfigurer#configuretasks()2、通过配置开启3、结合@async总结前言今天这篇文章介绍一下spring boot 中 如何开启多线程定时...
前言
今天这篇文章介绍一下spring boot 中 如何开启多线程定时任务?
为什么spring boot 定时任务是单线程的?
想要解释为什么,一定要从源码入手,直接从@enablescheduling这个注解入手,找到了这个scheduledtaskregistrar类,其中有一段代码如下:
protected void scheduletasks() { if (this.taskscheduler == null) { this.localexecutor = executors.newsinglethreadscheduledexecutor(); this.taskscheduler = new concurrenttaskscheduler(this.localexecutor); } }
如果taskscheduler为null,则创建单线程的线程池:executors.newsinglethreadscheduledexecutor()。
多线程定时任务如何配置?
下面介绍三种方案配置多线程下的定时任务。
1、重写schedulingconfigurer#configuretasks()
直接实现schedulingconfigurer这个接口,设置taskscheduler,代码如下:
@configuration public class scheduleconfig implements schedulingconfigurer { @override public void configuretasks(scheduledtaskregistrar taskregistrar) { //设定一个长度10的定时任务线程池 taskregistrar.setscheduler(executors.newscheduledthreadpool(10)); } }
2、通过配置开启
spring boot quartz 已经提供了一个配置用来配置线程池的大小,如下;
spring.task.scheduling.pool.size=10
只需要在配置文件中添加如上的配置即可生效!
3、结合@async
@async这个注解都用过,用来开启异步任务的,使用@async这个注解之前一定是要先配置线程池的,配置如下:
@bean public threadpooltaskexecutor taskexecutor() { threadpooltaskexecutor pooltaskexecutor = new threadpooltaskexecutor(); pooltaskexecutor.setcorepoolsize(4); pooltaskexecutor.setmaxpoolsize(6); // 设置线程活跃时间(秒) pooltaskexecutor.setkeepaliveseconds(120); // 设置队列容量 pooltaskexecutor.setqueuecapacity(40); pooltaskexecutor.setrejectedexecutionhandler(new threadpoolexecutor.callerrunspolicy()); // 等待所有任务结束后再关闭线程池 pooltaskexecutor.setwaitfortaskstocompleteonshutdown(true); return pooltaskexecutor; }
然后在@scheduled方法上标注@async这个注解即可实现多线程定时任务,代码如下:
@async @scheduled(cron = "0/2 * * * * ? ") public void test2() { system.out.println("..................执行test2................."); }
总结
本篇文章介绍了spring boot 中 实现多线程定时任务的三种方案,你喜欢哪一种?
到此这篇关于spring boot多个定时任务阻塞问题解决的文章就介绍到这了,更多相关springboot多定时任务阻塞内容请搜索以前的文章或继续浏览下面的相关文章希望大家以后多多支持!
上一篇: python jieba库的基本使用
下一篇: 今后输出表格之范例div表格
推荐阅读
-
Spring Boot+Quartz实现一个实时管理的定时任务
-
Spring Boot实现简单的定时任务
-
Spring Boot与Kotlin定时任务的示例(Scheduling Tasks)
-
定时任务每次都执行两次的问题,慎用new ClassPathXmlApplicationContext() -
Spring Boot中配置定时任务、线程池与多线程池执行的方法
-
spring定时器定时任务到时间未执行问题的解决
-
spring boot项目导入依赖后代码报错问题的解决方法
-
C#中定时任务被阻塞问题的解决方法
-
Spring Boot多个定时任务阻塞问题的解决方法
-
java定时任务_Spring Boot 整合 Quartz 实现 Java 定时任务的动态配置