温馨提示×

温馨提示×

您好,登录后才能下订单哦!

密码登录×
登录注册×
其他方式登录
点击 登录注册 即表示同意《亿速云用户服务条款》

SpringBoot中怎么异步调用方法并接收返回值

发布时间:2021-06-24 17:05:47 来源:亿速云 阅读:519 作者:Leah 栏目:编程语言

这期内容当中小编将会给大家带来有关SpringBoot中怎么异步调用方法并接收返回值,文章内容丰富且以专业的角度为大家分析和叙述,阅读完这篇文章希望大家可以有所收获。

步骤1:配置线程池,添加@Configuration和@EnableAsync注解

@Configuration@EnableAsyncpublic class ExecutorConfig {    /**   * 线程池   *   * @return   */  @Bean(name = "asyncExecutor")  public Executor asyncExecutor() {    ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();    executor.setCorePoolSize(10);    executor.setMaxPoolSize(15);    executor.setQueueCapacity(25);    executor.setKeepAliveSeconds(200);    executor.setThreadNamePrefix("async-");    executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());    // 等待所有任务都完成再继续销毁其他的Bean    executor.setWaitForTasksToCompleteOnShutdown(true);    // 线程池中任务的等待时间,如果超过这个时候还没有销毁就强制销毁,以确保应用最后能够被关闭,而不是阻塞住    executor.setAwaitTerminationSeconds(60);    executor.initialize();    return executor;  }  }

步骤2:定义方法A,方法B,方法C,方法D

@Servicepublic class AsyncService {   @Async("asyncExecutor")  public Future<Integer> methodB(){    try{      Thread.sleep(1000);    } catch (Exception e) {      e.printStackTrace();    }    return new AsyncResult<>(1);  }   @Async("asyncExecutor")  public Future<Integer> methodC(){    try{      Thread.sleep(2000);    } catch (Exception e) {      e.printStackTrace();    }    return new AsyncResult<>(2);  }   @Async("asyncExecutor")  public Future<Integer> methodD(){    try{      Thread.sleep(3000);    } catch (Exception e) {      e.printStackTrace();    }    return new AsyncResult<>(3);  }}@GetMapping("test")  public Integer methodA() throws Exception{    long start = System.currentTimeMillis();    Future<Integer> future1 = asyncService.methodB();    Future<Integer> future2 = asyncService.methodC();    Future<Integer> future3 = asyncService.methodD();    Integer x = future1.get();    Integer y = future2.get();    Integer z = future3.get();    long end = System.currentTimeMillis();    System.out.println("耗时:" + (end - start));    return x + y +z;  }}

上述就是小编为大家分享的SpringBoot中怎么异步调用方法并接收返回值了,如果刚好有类似的疑惑,不妨参照上述分析进行理解。如果想知道更多相关知识,欢迎关注亿速云行业资讯频道。

向AI问一下细节

免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。

AI