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

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(){

trhttp://y{

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);

} 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("耗时：" + (eHoULOfnd - start));

return x + y +z;

}

}

结果：

关于Futura类的详解请移步：了解java Future类

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。