如何并行处理多个任务并等待每个任务的成功与失败

Question

我有大约5个与从HTTP获取数据以及基于数据处理和生成结果相关的任务。

我希望并行运行这些任务，并等待所有任务成功完成或其中一个任务失败。每个任务都应该能够发布失败原因。如果其中一项任务失败，那么所有任务都将被视为失败，并在不等待所有任务完成的情况下退出。

我试图使用完整的未来和未来列表来实现它，但它不起作用，代码也不能很好地发布。

我有没有更好的方法来实现它？以身作则会有所帮助。

Answer 1

并行运行任务的最佳方法是使用具有可完成未来的Executor服务
如果一项任务失败，您必须考虑异常处理。

在这种情况下，几乎没有可能：

>

QuoteUtil quoteUtil = new QuoteUtil();
ExecutorService executor = Executors.newWorkStealingPool();

CompletableFuture
        .supplyAsync(quoteUtil::emptyQuote, executor)
        .thenApply(String::length)
        .exceptionally(exception -> "No quote available")
        .thenAccept(System.out::println);

executor.shutdown();
executor.awaitTermination(Integer.MAX_VALUE, TimeUnit.SECONDS);

对于异常处理程序：

CompletableFuture
        .supplyAsync(quoteUtil::emptyQuote, executor)
        .thenApply(String::length)
        .handle((result, throwable) -> {
            if (throwable != null) {
                return "No quote available: "
                        + throwable;
            } else {
                return result.toString();
            }
        })
        .thenAccept(System.out::println);

然后应用（）异常：

try {
    CompletableFuture
            .supplyAsync(quoteUtil::emptyQuote, executor)
            .thenApply(String::length)
            .thenAccept(System.out::println)
            .get();
} catch (Exception ex) {
    ex.printStackTrace();
} finally {
    executor.shutdown();
}

代码片段只显示一个调用。你也需要做同样的事情，但要完成一系列的任务。建立一份任务清单，并传递给可完成的未来，正如他在回答中所建议的那样。或者遍历这个列表，分别调用每个任务。

Answer 2

使用allOf静态方法或Stream方法。

方法1：-

CompletableFuture<Void> combinedFuture 
  = CompletableFuture.allOf(future1, future2, future3);

combinedFuture.get(); 

静态CompletableFuture allOf（CompletableFuture... cfs）返回一个新的CompletableFuture，当所有给定的CompletableFutures完成时完成。

在这种方法中，您需要单独获得未来对象的结果，并执行进一步的处理。

方法2：-

方法2中的优点是，假设Future返回String对象，未来的结果由单个空格连接和分隔。

String combined = Stream.of(future1, future2, future3)
  .map(CompletableFuture::join)
  .collect(Collectors.joining(" "));