原文 : https://blog.csdn.net/m0_37606574/article/details/87805473

多线程异步调用的使用场景：在复杂业务逻辑中，交易链路过长，使用多线程异步服务来提高效率

1、线程池配置类

  1. import org.slf4j.Logger;
  2. import org.slf4j.LoggerFactory;
  3. import org.springframework.context.annotation.Bean;
  4. import org.springframework.context.annotation.Configuration;
  5. import org.springframework.scheduling.annotation.EnableAsync;
  6. import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
  8. import java.util.concurrent.ExecutorService;
  9. import java.util.concurrent.ThreadPoolExecutor;
  11. /**
  12.  * 线程池配置
  13.  */
  14. @Configuration
  15. @EnableAsync//开启异步调用
  16. public class ThreadExecutorConfig {
  18.     private final Logger logger = LoggerFactory.getLogger(this.getClass());
  19.     /** 核心线程数 */
  20.     private int corePoolSize = 10;
  21.     /** 最大线程数 */
  22.     private int maxPoolSize = 200;
  23.     /** 队列数 */
  24.     private int queueCapacity = 10;
  26.     /**
  27.      * @Configuration = <beans></beans>
  28.      * @Bean = <bean></bean>
  29.      * 返回值类型为<bean></bean>中的属性"class"对应的value
  30.      * 方法名为<bean></bean>中的属性"id"对应的value
  31.      * @return
  32.      */
  33.     @Bean
  34.     public ExecutorService testFxbDrawExecutor(){
  35.         logger.info("start executor testExecutor ");
  36.         ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
  37.         executor.setCorePoolSize(corePoolSize);
  38.         executor.setMaxPoolSize(maxPoolSize);
  39.         executor.setQueueCapacity(queueCapacity);
  40.         executor.setThreadNamePrefix("test-fxb-draw-service-");
  42.         // rejection-policy：当pool已经达到max size的时候，如何处理新任务
  43.         // CALLER_RUNS：不在新线程中执行任务，而是有调用者所在的线程来执行
  44.         executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
  45.         // 执行初始化
  46.         executor.initialize();
  47.         return executor.getThreadPoolExecutor();
  48.     }
  50. }

2、依赖注入异步服务

注：配置的 name 值，引用上面配置的方法名，即 的 id

image.png

3、实际应用中的代码（业务逻辑中的一段代码），至此已经可以在业务中使用多线程了：

  1. Future<Map> queryAcct = asyncService.submit(() -> {
  2.     logger.info("--------------------1.1二类户查询------------------");
  3.     return accountInfoApi.queryCardInfo(conCurrParams);
  4. });
  6. Future<String> queryCoreDate = asyncService.submit(() -> {
  7.     logger.info("--------------------1.2查询核心时间------------------");
  8.     return getCoreDateService.getCoreDate();
  9. });
  11. Future<Map> queryCustomCertifiedInfo = asyncService.submit(() -> {
  12.     logger.info("--------------------1.3验证身份证到期日------------------");
  13.     return customInfoApi.queryCustomCertifiedInfo(conCurrParams);
  14. });
  16. try {
  17.     Map acctInfo = queryAcct.get();//异步调dubbo查询二类户的返回结果
  18.     String coreDate = queryCoreDate.get();//异步调dubbo查询核心时间的返回结果
  19.     Map customCertifiedInfo = queryCustomCertifiedInfo.get();//异步调dubbo查询身份证信息的返回结果
  20. } catch (Exception e) {
  21.     e.printStackTrace();
  22. }

4、代码解释：

image.png