Springboot集成定时器和多线程异步处理操作
更新时间：2020年09月30日 10:04:04 作者：PascalLee
这篇文章主要介绍了Springboot集成定时器和多线程异步处理操作，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧
需求:用@schedule标签进行定时处理逻辑,由于业务处理速度慢,需要每次执行逻辑放在不同的线程里异步执行
springboot集成多线程异步,直接上配置:
/**
* 线程池异步配置
*/
@Configuration
@EnableAsync
public class ThreadExecutorConfig
implements AsyncConfigurer {
@Override
public Executor getAsyncExecutor() {
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
// 设置核心线程数
executor.setCorePoolSize(5);
// 设置最大线程数
executor.setMaxPoolSize(7);
// 设置队列容量
executor.setQueueCapacity(20);
// 设置线程活跃时间（秒）
executor.setKeepAliveSeconds(60);
// 设置默认线程名称
executor.setThreadNamePrefix("PASCAL-");
// 设置拒绝策略
executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
// 等待所有任务结束后再关闭线程池
executor.setWaitForTasksToCompleteOnShutdown(true);
executor.initialize();
return executor;
}
@Override
public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
return new MyAsyncUncaughtExceptionHandler();
}
}
下面的是对多线程异步的时候报出的异常处理方法,可以自定义一个处理多线程异常类来实现自身的业务逻辑.
import org.springframework.aop.interceptor.AsyncUncaughtExceptionHandler;
import java.lang.reflect.Method;
public class MyAsyncUncaughtExceptionHandler implements
AsyncUncaughtExceptionHandler {
@Override
public void handleUncaughtException(Throwable ex,
Method method, Object... params) {
// handle exception
}
}
启动类上要记得添加异步和开启定时器的标签
@SpringBootApplication
@EnableScheduling
@Async
public class MultithreadingApplication {
public static void main(String[] args) {
SpringApplication.run(MultithreadingApplication.class, args);
}
}
业务逻辑方法:
@Async
@Scheduled(initialDelay=1000,fixedDelay = 5000)
public void test(){
SimpleDateFormat format=new SimpleDateFormat("HH:mm:ss");
try {
logger.info("当前线程为:"+Thread.currentThread().getName()+",方法开始时间为:"+format.format(new Date()));
Thread.sleep(10000);
logger.info("当前线程为:"+Thread.currentThread().getName()+",方法结束时间为:"+format.format(new Date()));
} catch (InterruptedException e) {
e.printStackTrace();
}
}
对于@Schedule注解的使用方法:
点进去可以看到有几个可选参数:
fixedDelay:控制方法执行的间隔时间，是以上一次方法执行完开始算起，如上一次方法执行阻塞住了，那么直到上一次执行完，并间隔给定的时间后，执行下一次
fixedRate:是按照一定的速率执行，是从上一次方法执行开始的时间算起，如果上一次方法阻塞住了，下一次也是不会执行，但是在阻塞这段时间内累计应该执行的次数，当不再阻塞时，一下子把这些全部执行掉，而后再按照固定速率继续执行。
initialDelay:如： @Scheduled(initialDelay = 10000,fixedRate = 15000
这个定时器就是在上一个的基础上加了一个initialDelay = 10000 意思就是在容器启动后,延迟10秒后再执行一次定时器,以后每15秒再执行一次该定时器.
cron表达式可以定制化执行任务，但是执行的方式是与fixedDelay相近的，也是会按照上一次方法结束时间开始算起。
这里可以根据自身的业务需求,看到底选择哪一个更适合,这里cron表达式就不再多言,可以结合自身应用场景来定
这样,需求就实现了
测试结果:
20-07-07 11:12:40.436 INFO 32360 --- [ main] o.s.b.w.embedded.tomcat.TomcatWebServer : Tomcat started on port(s): 8081 (http) with context path '' 2020-07-07 11:12:40.444 INFO 32360 --- [ main] c.e.m.MultithreadingApplication : Started MultithreadingApplication in 1.223 seconds (JVM running for 1.739) 2020-07-07 11:12:41.445 INFO 32360 --- [ scheduling-1] o.s.s.concurrent.ThreadPoolTaskExecutor : Initializing ExecutorService 2020-07-07 11:12:41.452 INFO 32360 --- [ PASCAL-1] c.e.multithreading.service.TestService : 当前线程为:PASCAL-1,方法开始时间为:11:12:41 2020-07-07 11:12:46.448 INFO 32360 --- [ PASCAL-2] c.e.multithreading.service.TestService : 当前线程为:PASCAL-2,方法开始时间为:11:12:46 2020-07-07 11:12:51.450 INFO 32360 --- [ PASCAL-3] c.e.multithreading.service.TestService : 当前线程为:PASCAL-3,方法开始时间为:11:12:51 2020-07-07 11:12:51.453 INFO 32360 --- [ PASCAL-1] c.e.multithreading.service.TestService : 当前线程为:PASCAL-1,方法结束时间为:11:12:51 2020-07-07 11:12:56.449 INFO 32360 --- [ PASCAL-2] c.e.multithreading.service.TestService : 当前线程为:PASCAL-2,方法结束时间为:11:12:56 2020-07-07 11:12:56.450 INFO 32360 --- [ PASCAL-4] c.e.multithreading.service.TestService : 当前线程为:PASCAL-4,方法开始时间为:11:12:56 2020-07-07 11:13:01.450 INFO 32360 --- [ PASCAL-3] c.e.multithreading.service.TestService : 当前线程为:PASCAL-3,方法结束时间为:11:13:01 2020-07-07 11:13:01.452 INFO 32360 --- [ PASCAL-5] c.e.multithreading.service.TestService : 当前线程为:PASCAL-5,方法开始时间为:11:13:01 2020-07-07 11:13:06.451 INFO 32360 --- [ PASCAL-4] c.e.multithreading.service.TestService : 当前线程为:PASCAL-4,方法结束时间为:11:13:06 2020-07-07 11:13:06.453 INFO 32360 --- [ PASCAL-1] c.e.multithreading.service.TestService : 当前线程为:PASCAL-1,方法开始时间为:11:13:06 2020-07-07 11:13:11.453 INFO 32360 --- [ PASCAL-5] c.e.multithreading.service.TestService : 当前线程为:PASCAL-5,方法结束时间为:11:13:11 2020-07-07 11:13:11.455 INFO 32360 --- [ PASCAL-2] c.e.multithreading.service.TestService : 当前线程为:PASCAL-2,方法开始时间为:11:13:11 2020-07-07 11:13:16.453 INFO 32360 --- [ PASCAL-1] c.e.multithreading.service.TestService : 当前线程为:PASCAL-1,方法结束时间为:11:13:16 2020-07-07 11:13:16.455 INFO 32360 --- [ PASCAL-3] c.e.multithreading.service.TestService : 当前线程为:PASCAL-3,方法开始时间为:11:13:16 2020-07-07 11:13:21.456 INFO 32360 --- [ PASCAL-2] c.e.multithreading.service.TestService : 当前线程为:PASCAL-2,方法结束时间为:11:13:21 2020-07-07 11:13:21.457 INFO 32360 --- [ PASCAL-4] c.e.multithreading.service.TestService : 当前线程为:PASCAL-4,方法开始时间为:11:13:21 2020-07-07 11:13:26.456 INFO 32360 --- [ PASCAL-3] c.e.multithreading.service.TestService : 当前线程为:PASCAL-3,方法结束时间为:11:13:26 2020-07-07 11:13:26.457 INFO 32360 --- [ PASCAL-5] c.e.multithreading.service.TestService : 当前线程为:PASCAL-5,方法开始时间为:11:13:26 2020-07-07 11:13:31.458 INFO 32360 --- [ PASCAL-4] c.e.multithreading.service.TestService : 当前线程为:PASCAL-4,方法结束时间为:11:13:31 2020-07-07 11:13:31.459 INFO 32360 --- [ PASCAL-1] c.e.multithreading.service.TestService : 当前线程为:PASCAL-1,方法开始时间为:11:13:31 2020-07-07 11:13:36.458 INFO 32360 --- [ PASCAL-5] c.e.multithreading.service.TestService : 当前线程为:PASCAL-5,方法结束时间为:11:13:36 2020-07-07 11:13:36.460 INFO 32360 --- [ PASCAL-2] c.e.multithreading.service.TestService : 当前线程为:PASCAL-2,方法开始时间为:11:13:36 2020-07-07 11:13:41.459 INFO 32360 --- [ PASCAL-1] c.e.multithreading.service.TestService : 当前线程为:PASCAL-1,方法结束时间为:11:13:41 2020-07-07 11:13:41.462 INFO 32360 --- [ PASCAL-3] c.e.multithreading.service.TestService : 当前线程为:PASCAL-3,方法开始时间为:11:13:41 2020-07-07 11:13:46.461 INFO 32360 --- [ PASCAL-2] c.e.multithreading.service.TestService : 当前线程为:PASCAL-2,方法结束时间为:11:13:46
每隔五秒执行一次
-----------------------分割线-----------------------
如果有多个定时任务,每个任务需要在不同的线程间处理的话,就要用另外的配置:如下:
/**
* 配置多个schedule的线程配置
*/
@Configuration
@EnableScheduling
public class ScheduleConfig implements SchedulingConfigurer{
/*
* 并行任务
*/
public void configureTasks(ScheduledTaskRegistrar taskRegistrar)
{
ThreadPoolTaskScheduler taskScheduler = new ThreadPoolTaskScheduler();
taskScheduler.setThreadNamePrefix("Schedule-Task-");
taskScheduler.setPoolSize(5);
taskScheduler.setAwaitTerminationSeconds(60);
taskScheduler.setWaitForTasksToCompleteOnShutdown(true);
taskScheduler.initialize();
taskRegistrar.setTaskScheduler(taskScheduler);
}
}
业务如下:
@Scheduled(cron = "*/5 * * * * ?")
public void test1(){
SimpleDateFormat format=new SimpleDateFormat("HH:mm:ss");
try {
logger.info("当前线程为:"+Thread.currentThread().getName()+",方法开始时间为:"+format.format(new Date()));
Thread.sleep(10000);
logger.info("当前线程为:"+Thread.currentThread().getName()+",方法结束时间为:"+format.format(new Date()));
} catch (InterruptedException e) {
e.printStackTrace();
}
}
@Scheduled(cron = "*/5 * * * * ?")
public void test2(){
SimpleDateFormat format=new SimpleDateFormat("HH:mm:ss");
try {
logger.info("当前线程为:"+Thread.currentThread().getName()+",方法开始时间为:"+format.format(new Date()));
Thread.sleep(10000);
logger.info("当前线程为:"+Thread.currentThread().getName()+",方法结束时间为:"+format.format(new Date()));
} catch (InterruptedException e) {
e.printStackTrace();
}
}
测试结果:
2020-07-07 11:34:53.101 INFO 27440 --- [ main] c.e.m.MultithreadingApplication : Started MultithreadingApplication in 1.147 seconds (JVM running for 1.74) 2020-07-07 11:34:55.002 INFO 27440 --- [Schedule-Task-2] c.e.multithreading.service.TestService : 当前线程为:Schedule-Task-2,方法开始时间为:11:34:55 2020-07-07 11:34:55.002 INFO 27440 --- [Schedule-Task-1] c.e.multithreading.service.TestService : 当前线程为:Schedule-Task-1,方法开始时间为:11:34:55 2020-07-07 11:35:05.003 INFO 27440 --- [Schedule-Task-2] c.e.multithreading.service.TestService : 当前线程为:Schedule-Task-2,方法结束时间为:11:35:05 2020-07-07 11:35:05.003 INFO 27440 --- [Schedule-Task-1] c.e.multithreading.service.TestService : 当前线程为:Schedule-Task-1,方法结束时间为:11:35:05 2020-07-07 11:35:10.001 INFO 27440 --- [Schedule-Task-2] c.e.multithreading.service.TestService : 当前线程为:Schedule-Task-2,方法开始时间为:11:35:10 2020-07-07 11:35:10.001 INFO 27440 --- [Schedule-Task-1] c.e.multithreading.service.TestService : 当前线程为:Schedule-Task-1,方法开始时间为:11:35:10 2020-07-07 11:35:20.001 INFO 27440 --- [Schedule-Task-2] c.e.multithreading.service.TestService : 当前线程为:Schedule-Task-2,方法结束时间为:11:35:20 2020-07-07 11:35:20.002 INFO 27440 --- [Schedule-Task-1] c.e.multithreading.service.TestService : 当前线程为:Schedule-Task-1,方法结束时间为:11:35:20 2020-07-07 11:35:25.001 INFO 27440 --- [Schedule-Task-1] c.e.multithreading.service.TestService : 当前线程为:Schedule-Task-1,方法开始时间为:11:35:25 2020-07-07 11:35:25.003 INFO 27440 --- [Schedule-Task-3] c.e.multithreading.service.TestService : 当前线程为:Schedule-Task-3,方法开始时间为:11:35:25 2020-07-07 11:35:35.001 INFO 27440 --- [Schedule-Task-1] c.e.multithreading.service.TestService : 当前线程为:Schedule-Task-1,方法结束时间为:11:35:35 2020-07-07 11:35:35.003 INFO 27440 --- [Schedule-Task-3] c.e.multithreading.service.TestService : 当前线程为:Schedule-Task-3,方法结束时间为:11:35:35 2020-07-07 11:35:40.002 INFO 27440 --- [Schedule-Task-1] c.e.multithreading.service.TestService : 当前线程为:Schedule-Task-1,方法开始时间为:11:35:40 2020-07-07 11:35:40.002 INFO 27440 --- [Schedule-Task-5] c.e.multithreading.service.TestService : 当前线程为:Schedule-Task-5,方法开始时间为:11:35:40 2020-07-07 11:35:50.002 INFO 27440 --- [Schedule-Task-1] c.e.multithreading.service.TestService : 当前线程为:Schedule-Task-1,方法结束时间为:11:35:50 2020-07-07 11:35:50.002 INFO 27440 --- [Schedule-Task-5] c.e.multithreading.service.TestService : 当前线程为:Schedule-Task-5,方法结束时间为:11:35:50
以上这篇Springboot集成定时器和多线程异步处理操作就是小编分享给大家的全部内容了，希望能给大家一个参考，也希望大家多多支持脚本之家。
相关文章
mybatis的mapper特殊字符转移及动态SQL条件查询小结
mybatis mapper文件中条件查询符，如>=,<,之类是不能直接写的会报错的需要转移一下，本文给大家介绍了常见的条件查询操作，对mybatis的mapper特殊字符及动态SQL条件查询相关知识感兴趣的朋友一起看看吧2021-09-09
Java中Arrays.sort自定义一维数组、二维数组的排序方式
这篇文章主要介绍了Java中Arrays.sort自定义一维数组、二维数组的排序方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教2023-08-08
这篇文章主要介绍了浅谈Spring中HandlerMapping的使用,Spingmvc中的HandlerMapping负责解析请求URL,对应到Handler进行处理,这里的Handler一般为Controller里的一个方法method,也可以为servlet或者Controller等,需要的朋友可以参考下2023-08-08
本文主要介绍了java使用ffmpeg命令来实现视频编码转换的示例,可以通过调用系统命令来执行FFmpeg命令,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧2024-07-07
这篇文章主要介绍了Eclipse Debug模式的开启与关闭问题简析，同时向大家介绍了一个简单的debug模式启动不起来的解决方法，希望对大家有所帮助。2017-10-10
SpringBoot中的自定义FailureAnalyzer详解
这篇文章主要介绍了SpringBoot中的自定义FailureAnalyzer详解,FailureAnalyzer是一种很好的方式在启动时拦截异常并将其转换为易读的消息,并将其包含在FailureAnalysis中, Spring Boot为应用程序上下文相关异常、JSR-303验证等提供了此类分析器,需要的朋友可以参考下2023-12-12
这篇文章主要介绍了多线程如何解决for循环效率的问题，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2021-06-06
如果目标位置没有同名文件，则直接拷贝过去；如果目标位置已有同名文件，则比对文件的最后修改日期，来进行覆盖或者忽略。程序会在可以在复制过程中自动创建目录，并生成log文件，创建了哪些目录、文件，覆盖了哪些文件、跳过了哪些文件，文件的时间、位置等信息都一目了然2014-01-01
SpringBoot异常处理器的使用与添加员工功能实现流程介绍
设计完了登录与退出功能还只完成了冰山一角，经过测试发现，我们以url的方式来访问网站时可以直接跳过登陆页面进入后台页面，这样显然是不合理的，下面我们通过异常拦截器+boot来做到访问限制，以及实现新增员工功能，制作全局异常处理器2022-10-10
Java中注解@JsonFormat与@DateTimeFormat的使用
从数据库获取时间传到前端进行展示的时候,我们有时候可能无法得到一个满意的时间格式的时间日期,本文主要介绍了Java中注解@JsonFormat与@DateTimeFormat的使用,文中通过示例代码介绍的非常详细,需要的朋友们下面随着小编来一起学习学习吧2023-08-08
最新评论