在运行异步任务流时使用 CompletableFuture 的最佳方法是什么？

Question

我有一个 Spring 组件 EventSvcFacade，它具有三个 EventValidationSvc 实现类实例的列表。这些类中的每一个都实现了方法boolean validate(T request)，接受相同的输入，但在输入上调用不同的API，处理结果并返回一个布尔值。因此，该流程是为并发调用而设计的。我想出了两种从任务流中返回布尔值列表的方法。任何人都可以建议，在哪些因素上一种方法比另一种更好，或者还有其他更好的方法吗？

@Component
public class EventSvcFacade {

    @Autowired
    private List<EventValidationSvc<EventRequest>> validationSvcs;

    @Autowired
    private ThreadPoolExecutor threadPoolExecutor;

    public List<Boolean> firstApproach(){
      final List<CompletableFuture<Boolean>> futures = validationSvcs.stream().map(service -> 
            CompletableFuture.supplyAsync(() -> service.validate(eventRequest), threadPoolExecutor))
            .collect(Collectors.toList());                                                                                      
      final List<Boolean> values = futures.stream().map(CompletableFuture :: 
            join).collect(Collectors.toList());
      return values;
    }

    public List<Boolean> secondApproach() {
      final List<Boolean> values = Collections.synchronizedList(new ArrayList<>());
      final CountDownLatch countDownLatch = new CountDownLatch(validationSvcs.size());
      validationSvcs.stream().forEach(service -> CompletableFuture.runAsync(() -> {         
            try{
             values.add(service.validate(eventRequest));
            }finally{
             countDownLatch.countDown();
            }
          }, threadPoolExecutor)
      );
      countDownLatch.await();
      return values;
   }
}

Answer 1

第一种方法更简洁，因为它是pure：因为它不依赖副作用，所以更容易推理并且在以后修改代码时不太可能中断。

此外，第一种方法不依赖于 ad-hoc 同步结构，例如第二种方法对 CountDownLatch 实例所做的那样。如果您的先决条件发生变化并且只有两个服务可以调用，第一种方法将继续有效，而第二种方法将永远不会返回。