个人中心
gpt4 book ai didi

Spring Boot利用@Async如何实现异步调用：自定义线程池

转载 作者：qq735679552 更新时间：2022-09-27 22:32:09 25 4
gpt4 key购买 nike

CFSDN坚持开源创造价值，我们致力于搭建一个资源共享平台，让每一个IT人在这里找到属于你的精彩世界.

这篇CFSDN的博客文章Spring Boot利用@Async如何实现异步调用：自定义线程池由作者收集整理，如果你对这篇文章有兴趣，记得点赞哟.

前言 。

在之前的Spring Boot基础教程系列中，已经通过《Spring Boot中使用@Async实现异步调用》一文介绍过如何使用@Async注解来实现异步调用了。但是，对于这些异步执行的控制是我们保障自身应用健康的基本技能。本文我们就来学习一下，如果通过自定义线程池的方式来控制异步调用的并发.

本文中的例子我们可以在之前的例子基础上修改，也可以创建一个全新的Spring Boot项目来尝试.

定义线程池 。

第一步，先在Spring Boot主类中定义一个线程池，比如:

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
@SpringBootApplication
public class Application {
  public static void main(String[] args) {
   SpringApplication.run(Application. class , args);
  }
 
  @EnableAsync
  @Configuration
  class TaskPoolConfig {
 
   @Bean ( "taskExecutor" )
   public Executor taskExecutor() {
    ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
    executor.setCorePoolSize( 10 );
    executor.setMaxPoolSize( 20 );
    executor.setQueueCapacity( 200 );
    executor.setKeepAliveSeconds( 60 );
    executor.setThreadNamePrefix( "taskExecutor-" );
    executor.setRejectedExecutionHandler( new ThreadPoolExecutor.CallerRunsPolicy());
    return executor;
   }
  }
}

上面我们通过使用ThreadPoolTaskExecutor创建了一个线程池，同时设置了以下这些参数:

  • 核心线程数10：线程池创建时候初始化的线程数
  • 最大线程数20：线程池最大的线程数，只有在缓冲队列满了之后才会申请超过核心线程数的线程
  • 缓冲队列200：用来缓冲执行任务的队列
  • 允许线程的空闲时间60秒：当超过了核心线程出之外的线程在空闲时间到达之后会被销毁
  • 线程池名的前缀：设置好了之后可以方便我们定位处理任务所在的线程池
  • 线程池对拒绝任务的处理策略：这里采用了CallerRunsPolicy策略，当线程池没有处理能力的时候，该策略会直接在 execute 方法的调用线程中运行被拒绝的任务；如果执行程序已关闭，则会丢弃该任务

使用线程池 。

在定义了线程池之后，我们如何让异步调用的执行任务使用这个线程池中的资源来运行呢？方法非常简单，我们只需要在@Async注解中指定线程池名即可，比如:

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
@Slf4j
@Component
public class Task {
  public static Random random = new Random();
  @Async ( "taskExecutor" )
  public void doTaskOne() throws Exception {
   log.info( "开始做任务一" );
   long start = System.currentTimeMillis();
   Thread.sleep(random.nextInt( 10000 ));
   long end = System.currentTimeMillis();
   log.info( "完成任务一，耗时：" + (end - start) + "毫秒" );
  }
 
  @Async ( "taskExecutor" )
  public void doTaskTwo() throws Exception {
   log.info( "开始做任务二" );
   long start = System.currentTimeMillis();
   Thread.sleep(random.nextInt( 10000 ));
   long end = System.currentTimeMillis();
   log.info( "完成任务二，耗时：" + (end - start) + "毫秒" );
  }
 
  @Async ( "taskExecutor" )
  public void doTaskThree() throws Exception {
   log.info( "开始做任务三" );
   long start = System.currentTimeMillis();
   Thread.sleep(random.nextInt( 10000 ));
   long end = System.currentTimeMillis();
   log.info( "完成任务三，耗时：" + (end - start) + "毫秒" );
  }
}

单元测试 。

?
1
2
3
4
5
6
7
8
9
10
11
12
13
@RunWith (SpringJUnit4ClassRunner. class )
@SpringBootTest
public class ApplicationTests {
  @Autowired
  private Task task;
  @Test
  public void test() throws Exception {
   task.doTaskOne();
   task.doTaskTwo();
   task.doTaskThree();
   Thread.currentThread().join();
  }
}

执行上面的单元测试，我们可以在控制台中看到所有输出的线程名前都是之前我们定义的线程池前缀名开始的，说明我们使用线程池来执行异步任务的试验成功了！ 。

2018-03-27 22:01:15.620  INFO 73703 --- [ taskExecutor-1] com.didispace.async.Task                 : 开始做任务一 2018-03-27 22:01:15.620  INFO 73703 --- [ taskExecutor-2] com.didispace.async.Task                 : 开始做任务二 2018-03-27 22:01:15.620  INFO 73703 --- [ taskExecutor-3] com.didispace.async.Task                 : 开始做任务三 2018-03-27 22:01:18.165  INFO 73703 --- [ taskExecutor-2] com.didispace.async.Task                 : 完成任务二，耗时：2545毫秒 2018-03-27 22:01:22.149  INFO 73703 --- [ taskExecutor-3] com.didispace.async.Task                 : 完成任务三，耗时：6529毫秒 2018-03-27 22:01:23.912  INFO 73703 --- [ taskExecutor-1] com.didispace.async.Task                 : 完成任务一，耗时：8292毫秒 。

完整示例:

读者可以根据喜好选择下面查看Chapter4-1-3项目:

Github：https://github.com/dyc87112/SpringBoot-Learning/ 。

Gitee：https://gitee.com/didispace/SpringBoot-Learning/ 。

总结 。

以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作具有一定的参考学习价值，如果有疑问大家可以留言交流，谢谢大家对我的支持.

原文链接：http://blog.didispace.com/springbootasync-2/ 。

最后此篇关于Spring Boot利用@Async如何实现异步调用：自定义线程池的文章就讲到这里了,如果你想了解更多关于Spring Boot利用@Async如何实现异步调用：自定义线程池的内容请搜索CFSDN的文章或继续浏览相关文章，希望大家以后支持我的博客！ 。

25 4 0
文章推荐： Windows上使用virtualenv搭建Python+Flask开发环境
文章推荐： 在Python的Flask中使用WTForms表单框架的基础教程
文章推荐： Spring Cloud微服务架构的构建：分布式配置中心（加密解密功能）
文章推荐： 详解Python的Flask框架中生成SECRET_KEY密钥的方法
qq735679552
个人简介

我是一名优秀的程序员,十分优秀！

滴滴打车优惠券免费领取
滴滴打车优惠券
全站热门文章
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com