@Async的异步任务多起来了，如何配置多个线程池来隔离任务？ |
您所在的位置：网站首页 › spring线程池的使用 › @Async的异步任务多起来了，如何配置多个线程池来隔离任务？ |
|
通过上一篇：配置@Async异步任务的线程池的介绍，你应该已经了解到异步任务的执行背后有一个线程池来管理执行任务。为了控制异步任务的并发不影响到应用的正常运作，我们必须要对线程池做好相应的配置，防止资源的过渡使用。除了默认线程池的配置之外，还有一类场景，也是很常见的，那就是多任务情况下的线程池隔离。 什么是线程池的隔离，为什么要隔离可能有的小伙伴还不太了解什么是线程池的隔离，为什么要隔离？。所以，我们先来看看下面的场景案例： @RestController public class HelloController { @Autowired private AsyncTasks asyncTasks; @GetMapping("/api-1") public String taskOne() { CompletableFuture task1 = asyncTasks.doTaskOne("1"); CompletableFuture task2 = asyncTasks.doTaskOne("2"); CompletableFuture task3 = asyncTasks.doTaskOne("3"); CompletableFuture.allOf(task1, task2, task3).join(); return ""; } @GetMapping("/api-2") public String taskTwo() { CompletableFuture task1 = asyncTasks.doTaskTwo("1"); CompletableFuture task2 = asyncTasks.doTaskTwo("2"); CompletableFuture task3 = asyncTasks.doTaskTwo("3"); CompletableFuture.allOf(task1, task2, task3).join(); return ""; } }上面的代码中，有两个API接口，这两个接口的具体执行逻辑中都会把执行过程拆分为三个异步任务来实现。 好了，思考一分钟，想一下。如果这样实现，会有什么问题吗？ 上面这段代码，在API请求并发不高，同时如果每个任务的处理速度也够快的时候，是没有问题的。但如果并发上来或其中某几个处理过程扯后腿了的时候。这两个提供不相干服务的接口可能会互相影响。比如：假设当前线程池配置的最大线程数有2个，这个时候/api-1接口中task1和task2处理速度很慢，阻塞了；那么此时，当用户调用api-2接口的时候，这个服务也会阻塞！ 造成这种现场的原因是：默认情况下，所有用@Async创建的异步任务都是共用的一个线程池，所以当有一些异步任务碰到性能问题的时候，是会直接影响其他异步任务的。 为了解决这个问题，我们就需要对异步任务做一定的线程池隔离，让不同的异步任务互不影响。 不同异步任务配置不同线程池下面，我们就来实际操作一下！ 第一步：初始化多个线程池，比如下面这样： @EnableAsync @Configuration public class TaskPoolConfig { @Bean public Executor taskExecutor1() { ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); executor.setCorePoolSize(2); executor.setMaxPoolSize(2); executor.setQueueCapacity(10); executor.setKeepAliveSeconds(60); executor.setThreadNamePrefix("executor-1-"); executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy()); return executor; } @Bean public Executor taskExecutor2() { ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); executor.setCorePoolSize(2); executor.setMaxPoolSize(2); executor.setQueueCapacity(10); executor.setKeepAliveSeconds(60); executor.setThreadNamePrefix("executor-2-"); executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy()); return executor; } }注意：这里特地用executor.setThreadNamePrefix设置了线程名的前缀，这样可以方便观察后面具体执行的顺序。 第二步：创建异步任务，并指定要使用的线程池名称 @Slf4j @Component public class AsyncTasks { public static Random random = new Random(); @Async("taskExecutor1") public CompletableFuture doTaskOne(String taskNo) throws Exception { log.info("开始任务：{}", taskNo); long start = System.currentTimeMillis(); Thread.sleep(random.nextInt(10000)); long end = System.currentTimeMillis(); log.info("完成任务：{}，耗时：{} 毫秒", taskNo, end - start); return CompletableFuture.completedFuture("任务完成"); } @Async("taskExecutor2") public CompletableFuture doTaskTwo(String taskNo) throws Exception { log.info("开始任务：{}", taskNo); long start = System.currentTimeMillis(); Thread.sleep(random.nextInt(10000)); long end = System.currentTimeMillis(); log.info("完成任务：{}，耗时：{} 毫秒", taskNo, end - start); return CompletableFuture.completedFuture("任务完成"); } }这里@Async注解中定义的taskExecutor1和taskExecutor2就是线程池的名字。由于在第一步中，我们没有具体写两个线程池Bean的名称，所以默认会使用方法名，也就是taskExecutor1和taskExecutor2。 第三步：写个单元测试来验证下，比如下面这样： @Slf4j @SpringBootTest public class Chapter77ApplicationTests { @Autowired private AsyncTasks asyncTasks; @Test public void test() throws Exception { long start = System.currentTimeMillis(); // 线程池1 CompletableFuture task1 = asyncTasks.doTaskOne("1"); CompletableFuture task2 = asyncTasks.doTaskOne("2"); CompletableFuture task3 = asyncTasks.doTaskOne("3"); // 线程池2 CompletableFuture task4 = asyncTasks.doTaskTwo("4"); CompletableFuture task5 = asyncTasks.doTaskTwo("5"); CompletableFuture task6 = asyncTasks.doTaskTwo("6"); // 一起执行 CompletableFuture.allOf(task1, task2, task3, task4, task5, task6).join(); long end = System.currentTimeMillis(); log.info("任务全部完成，总耗时：" + (end - start) + "毫秒"); } }在上面的单元测试中，一共启动了6个异步任务，前三个用的是线程池1，后三个用的是线程池2。 先不执行，根据设置的核心线程2和最大线程数2，来分析一下，大概会是怎么样的执行情况？ 线程池1的三个任务，task1和task2会先获得执行线程，然后task3因为没有可分配线程进入缓冲队列线程池2的三个任务，task4和task5会先获得执行线程，然后task6因为没有可分配线程进入缓冲队列任务task3会在task1或task2完成之后，开始执行任务task6会在task4或task5完成之后，开始执行分析好之后，执行下单元测试，看看是否是这样的： 2021-09-15 23:45:11.369 INFO 61670 --- [ executor-1-1] com.didispace.chapter77.AsyncTasks : 开始任务：1 2021-09-15 23:45:11.369 INFO 61670 --- [ executor-2-2] com.didispace.chapter77.AsyncTasks : 开始任务：5 2021-09-15 23:45:11.369 INFO 61670 --- [ executor-2-1] com.didispace.chapter77.AsyncTasks : 开始任务：4 2021-09-15 23:45:11.369 INFO 61670 --- [ executor-1-2] com.didispace.chapter77.AsyncTasks : 开始任务：2 2021-09-15 23:45:15.905 INFO 61670 --- [ executor-2-1] com.didispace.chapter77.AsyncTasks : 完成任务：4，耗时：4532 毫秒 2021-09-15 23:45:15.905 INFO 61670 --- [ executor-2-1] com.didispace.chapter77.AsyncTasks : 开始任务：6 2021-09-15 23:45:18.263 INFO 61670 --- [ executor-1-2] com.didispace.chapter77.AsyncTasks : 完成任务：2，耗时：6890 毫秒 2021-09-15 23:45:18.263 INFO 61670 --- [ executor-1-2] com.didispace.chapter77.AsyncTasks : 开始任务：3 2021-09-15 23:45:18.896 INFO 61670 --- [ executor-2-2] com.didispace.chapter77.AsyncTasks : 完成任务：5，耗时：7523 毫秒 2021-09-15 23:45:19.842 INFO 61670 --- [ executor-1-2] com.didispace.chapter77.AsyncTasks : 完成任务：3，耗时：1579 毫秒 2021-09-15 23:45:20.551 INFO 61670 --- [ executor-1-1] com.didispace.chapter77.AsyncTasks : 完成任务：1，耗时：9178 毫秒 2021-09-15 23:45:24.117 INFO 61670 --- [ executor-2-1] com.didispace.chapter77.AsyncTasks : 完成任务：6，耗时：8212 毫秒 2021-09-15 23:45:24.117 INFO 61670 --- [ main] c.d.chapter77.Chapter77ApplicationTests : 任务全部完成，总耗时：12762毫秒好了，今天的学习就到这里！更多Spring Boot教程可以点击文末阅读原文直达教程目录！ 代码示例本文的完整工程可以查看下面仓库中2.x目录下的chapter7-7工程： Github：https://github.com/dyc87112/SpringBoot-Learning/Gitee：https://gitee.com/didispace/SpringBoot-Learning/如果您觉得本文不错，欢迎Star支持，您的关注是我坚持的动力！ 往期推荐 六成大学生认为自己毕业10年内会年入百万！网友：知乎上多了，没被社会毒打过吧！ 缓存核心知识小抄，面试必备，赶紧收藏！ Java 17正式发布， Oracle宣布免费提供！“版本任你发，我用Java 8”或成历史？ Spring Boot 中使用@Async实现异步调用，加速任务执行！ 一个SpringMVC接口能返回JSON又能返回XML? 安排！ 技术交流群 最近有很多人问，有没有读者交流群，想知道怎么加入。加入方式很简单，有兴趣的同学，只需要点击下方卡片，回复“加群“，即可免费加入我们的高质量技术交流群！ 点击阅读原文，直达教程目录 |
今日新闻 |
推荐新闻 |
| CopyRight 2018-2019 办公设备维修网 版权所有 豫ICP备15022753号-3 |