• 欢迎访问搞代码网站,推荐使用最新版火狐浏览器和Chrome浏览器访问本网站!
  • 如果您觉得本站非常有看点,那么赶紧使用Ctrl+D 收藏搞代码吧

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

springboot 搞代码 4年前 (2022-01-05) 74次浏览 已收录 0个评论

这篇文章主要为大家详细介绍了SpringBoot异步调用方法并接收返回值,具有一定的参考价值,感兴趣的小伙伴们可以参考一下

项目中肯定会遇到异步调用其他方法的场景,比如有个计算过程,需要计算很多个指标的值,但是每个指标计算的效率快慢不同,如果采用同步执行的方式,运行这一个过程的时间是计算所有指标的时间之和。比如:

方法A:计算指标x,指标y,指标z的值,其中计算指标x需要1s,计算指标y需要2s,指标z需要3s。最终执行完方法A就是5s。

现在用异步的方式优化一下

方法A异步调用方法B,方法C,方法D,方法B,方法C,方法D分别计算指标x,指标y,指标z的值,那么最终执行完方法A的时间则是3s。

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

 @Configuration @EnableAsync public 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

 @Service public class AsyncService { @Async("asyncExecutor") public Future methodB(){ try{ Thread.sleep(1000); } catch (Exception e) { e.printStackTrace(); } return new AsyncResult(1); } @Async("asyncExecutor") public Future methodC(){ try{ Thread.sleep(2000); } catch (Exception e) { e.printStackTrace(); } return new AsyncResult(2); } @Async("asyncExecutor") public Future methodD(){ try{ Thread.sleep(3000); } <b style="color:transparent">来源gao@!dai!ma.com搞$$代^@码网</b>catch (Exception e) { e.printStackTrace(); } return new AsyncResult(3); } } @GetMapping("test") public Integer methodA() throws Exception{ long start = System.currentTimeMillis(); Future future1 = asyncService.methodB(); Future future2 = asyncService.methodC(); Future 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; } }

结果:

关于Futura类的详解请移步:了解JAVA Future类

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持gaodaima搞代码网

以上就是SpringBoot异步调用方法并接收返回值的详细内容,更多请关注gaodaima搞代码网其它相关文章!


搞代码网(gaodaima.com)提供的所有资源部分来自互联网,如果有侵犯您的版权或其他权益,请说明详细缘由并提供版权或权益证明然后发送到邮箱[email protected],我们会在看到邮件的第一时间内为您处理,或直接联系QQ:872152909。本网站采用BY-NC-SA协议进行授权
转载请注明原文链接:SpringBoot异步调用方法并接收返回值

喜欢 (0)
[搞代码]
分享 (0)
发表我的评论
取消评论

表情 贴图 加粗 删除线 居中 斜体 签到

Hi,您需要填写昵称和邮箱!

  • 昵称 (必填)
  • 邮箱 (必填)
  • 网址