我想要做一些未来的成交订单在CompletableFuture列表

Question

我有一些服务回报CompletableFutures这样

Set<CompletableFuture<String>> futures = service.getSomething(); 

for (CompletableFuture<String> future : futures) { 
    System.out.println(future.get()); 
} 

该代码打印值迭代顺序。但我希望首先使用完成服务。

Set<CompletableFuture<String>> futures = service.getSomething(); 
Set<CompletableFuture<String>> donefutures = new HashSet<>(); 

while (true) { 
    if (futures.equals(donefutures)) { 
     break; 
    } 

    futures 
      .stream() 
      .filter(f -> !donefutures.contains(f)) 
      .filter(CompletableFuture::isDone) 
      .peek(donefutures::add) 
      .map(f -> { 
       try { 
        return f.get(); 
       } catch (InterruptedException | ExecutionException e) { 
        return null; 
       } 
      }) 
      .forEach(System.out::println); 

    Thread.sleep(100); 
} 

我试过这种方式。它正在工作。但我认为真的很难看。有更好的方法吗？

Answer 1

您正在使用CompletableFuture（与Future一样）以阻塞方式运行无限循环。你必须指定回调函数，在将来完成时将调用它。

所以，你可以做这样的事情：

Set<CompletableFuture<String>> futures = service.getSomething(); 
futures.forEach(future -> future.whenComplete(
     (result, throwable) -> System.out.println(result) 
)); 

CompletableFuture 
    .allOf(futures.toArray(new CompletableFuture[0])) 
    .join();