SpringBoot实现多线程
发布日期:2021-07-01 02:43:22
浏览次数:2
分类:技术文章
本文共 3294 字,大约阅读时间需要 10 分钟。
文章目录
SpringBoot实现多线程
- SpringBoot通过
任务执行器TaskExecutor
来实现多线程和并发编程。 - 使用
TreadPoolTaskExecutor
可实现一个基于线程池的TaskExecutor
。 - 实际开发任务
一般是非阻碍的,即异步的
,所以我们要在配置类中通过@EnableAsync
开启对异步任务
的支持,并通过在实际执行的Bean中的方法使用@Async注解
来声明这是一个异步任务
。
0. 同步和异步
-
同步交互
:指发送一个请求,需要等待返回
,然后才能够发送下一个请求,有个等待过程; -
异步交互
:指发送一个请求,不需要等待返回
,随时可以再发送下一个请求,即不需要等待。
区别:一个需要等待,一个不需要等待。
在部分情况下
,我们的项目开发中都会优先
选择不需要等待的异步交互方式
。
1. 引入 Maven 依赖
org.springframework.boot spring-boot-starter 2.4.4
2. 异步执行的配置类 AsyncConfig
package com.melodyjerry.thread;import org.springframework.context.annotation.ComponentScan;import org.springframework.context.annotation.Configuration;import org.springframework.scheduling.annotation.AsyncConfigurer;import org.springframework.scheduling.annotation.EnableAsync;import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;import java.util.concurrent.Executor;/** * @classname AsyncConfig * @description 开启异步执行的配置类 */@Configuration@EnableAsync //开启异步执行@ComponentScan("com.melodyjerry.thread")public class AsyncConfig implements AsyncConfigurer { @Override public Executor getAsyncExecutor() { ThreadPoolTaskExecutor threadPoolTaskExecutor = new ThreadPoolTaskExecutor(); //线程池中的线程的名称前缀 threadPoolTaskExecutor.setThreadNamePrefix("SpringBoot线程池的前缀-"); //线程池的核心线程数大小 threadPoolTaskExecutor.setCorePoolSize(4); //线程池的最大线程数 threadPoolTaskExecutor.setMaxPoolSize(8); //等待队列的大小 threadPoolTaskExecutor.setQueueCapacity(25); //执行初始化 threadPoolTaskExecutor.initialize(); return threadPoolTaskExecutor; }}
3. 异步任务的执行类
package com.melodyjerry.thread;import org.springframework.scheduling.annotation.Async;import org.springframework.stereotype.Service;/** * @classname AsyncTaskService * @description 异步任务的执行类 */@Servicepublic class AsyncTaskService { @Async //异步方法 public void executeAsyncTask(Integer i) { System.out.println("执行异步任务: "+i); } @Async //异步方法 public void executeAsyncTaskPlus(Integer i) { System.out.println("执行异步任务+1: " + (i+1)); }}
@Async
注解表明该方法是个异步方法
。从Async注解接口可以看到,
Target
即可以在方法
也可以在类型
上,如果注解在类型上,表明该类所有的方法都是异步方法。
4. 测试效果 TestThreadApplication
package com.melodyjerry.thread;import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.SpringBootApplication;import org.springframework.context.ConfigurableApplicationContext;/** * @classname TestThreadApplication * @description 测试异步任务 */@SpringBootApplicationpublic class TestThreadApplication { public static void main(String[] args) { ConfigurableApplicationContext context = SpringApplication.run(TestThreadApplication.class, args); AsyncTaskService asyncTaskService = context.getBean(AsyncTaskService.class); for (int i = 0; i < 10; i++) { asyncTaskService.executeAsyncTask(i); asyncTaskService.executeAsyncTaskPlus(i); } System.out.println("This Program has Begun successfully"); }}
This Program has Begun successfully执行异步任务: 0执行异步任务: 2执行异步任务+1: 1执行异步任务+1: 3执行异步任务: 3执行异步任务: 4执行异步任务+1: 5执行异步任务: 5执行异步任务+1: 6执行异步任务+1: 2执行异步任务: 6执行异步任务+1: 4执行异步任务: 7执行异步任务: 8执行异步任务+1: 9执行异步任务: 9执行异步任务+1: 10执行异步任务+1: 7执行异步任务+1: 8执行异步任务: 1
转载地址:https://melodyjerry.blog.csdn.net/article/details/116108860 如侵犯您的版权,请留言回复原文章的地址,我们会给您删除此文章,给您带来不便请您谅解!
发表评论
最新留言
路过,博主的博客真漂亮。。
[***.116.15.85]2024年04月29日 06时04分30秒
关于作者
喝酒易醉,品茶养心,人生如梦,品茶悟道,何以解忧?唯有杜康!
-- 愿君每日到此一游!
推荐文章
Leetcode 35. 搜索插入位置 c#
2019-05-01
[9] JMeter-常用函数的使用
2019-05-01
[12] JMeter-结果分析之图形图表
2019-05-01
has been blocked by CORS policy: Response to preflight request doesn‘t pass access control check 报错
2019-05-01
使用aspose.words 18.6实现pdf文档转换
2019-05-01
Java数组详解
2019-05-01
Java面向对象详解
2019-05-01
vs中动态DLL与静态LIB工程中加入版本信息的方法
2019-05-01
大数据分析技术与应用一站式学习(值得收藏)_v20200418
2019-05-01
Qt 在windows下的串口读写
2019-05-01
SpringApplication执行流程
2019-05-01
自定义Starter
2019-05-01
分布式事务原理探究(一)
2019-05-01
spring cloud consul 应用的多实例名的解决
2019-05-01
人工智能为什么这么火?看看安防江湖30年血战就知道了
2019-05-01
“前端智能为安防产生新的数据价值”
2019-05-01
高斯混合模型
2019-05-01
(8)CMake入门笔记--CMake语法
2019-05-01
3D点云图实验
2019-05-01