并发请求下游多个服务

Future + 线程池+ countDownLatch 并发请求多个服务

  2. public String getDataFromAandB(){
  3.     CountDownLatch countDownLatch = new CountDownLatch(2);
  4.     Future<String> fa = getDataFromA(countDownLatch);
  5.     Future<String> fb = getDataFromB(countDownLatch);
  6.     countDownLatch.await();
  7.     String a = fa.get();
  8.     String b = fb.get();
  9.     return a+b；
  10. }
  13. @Async
  14. public Future<String> getDataFromA(CountDownLatch countDownLatch){
  15.    String a = getFromA()；
  16.   try{
  17.   return AsyncResult.forValue(a);
  18. .    }
  19.     catch(Exception e){
  20.     }
  21.     finally{
  22.       countDownLatch.countDown();
  23.     }
  24. }
  27. @Async
  28. public Future<String> getDataFromB(CountDownLatch countDownLatch){
  29.    // 请求B系统
  30.   String b = getFromB()；
  31.   try{
  32.   return AsyncResult.forValue(b);
  33. .    }
  34.     catch(Exception e){
  35.     }
  36.     finally{
  37.       countDownLatch.countDown();
  38.     }
  39. }

异步请求下游多个服务