SpringBoot异步调用方法并接收返回值
2019-10-25 18:07
1156 查看
项目中肯定会遇到异步调用其他方法的场景,比如有个计算过程,需要计算很多个指标的值,但是每个指标计算的效率快慢不同,如果采用同步执行的方式,运行这一个过程的时间是计算所有指标的时间之和。比如:
方法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<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; } }
结果:
关于Futura类的详解请移步:了解JAVA Future类
以上就是本文的全部内容,希望对大家的学习有所帮助
您可能感兴趣的文章:
相关文章推荐
- C++ 调用Python文件方法传递字典参数并接收返回值
- net ,js脚本调用后台方法不接收返回值
- C#线程池ThreadPool.QueueUserWorkItem接收线程执行的方法返回值
- springmvc 动态修改返回值类型,实现方法既能被ajax调用,又能被同步请求调用
- C# 委托/Func() 中 GetInvocationList() 方法的使用 | 接收委托多个返回值
- dwr 3.0 配置 + 不同参数,不同返回值调用方法 示例
- ajax同步请求,及js调用含ajax的方法的返回值问题
- android调用webservice方法,参数和返回值都用字符串
- dwr 3.0 配置 + 不同参数,不同返回值调用方法 示例
- Javascript设置Cookie 后台CS文件接收Cookie,cs文件调用javas的方法
- A框架 第二部 实例化接收到的get类,调用父类抽象方法,自动执行方法call_user_func_array()
- jQuery.validate.js第二次调用validate()方法时,返回值错误bug解决
- c#带参数和返回值的函数 开启线程调用的方法
- AllJoyn-跨平台方法调用返回值为自定义类型
- asp.net 调用post方法并获取返回值
- DWR 调用返回值方法
- Javascript设置Cookie 后台CS文件接收Cookie,cs文件调用javas的方法
- asp.net调用接收存储过程返回值
- 类的多参数,带返回值的静态方法的调用
- 代码段接收并遍历返回值为动态游标的方法