java-8 - CompletableFuture 具有异步运行的可变长度 Runnable 任务

Question

据我所知，目前缺少以下 api:

CompletableFuture future = null;
List<String> emails = ...
for(String email: emails) {
    future = future.runAsync(new SendEmailTask(email));
}

或

List<CompletableFuture> runAsync(List<Runnable> tasks);

当我看到它的文档或教程时，感觉用户需要知道有多少任务，并相应地“静态”编码。因此，我仍然使用 executors.invokeAll 来获取可变长度的任务列表。有没有一种方法可以使用 CompletableFuture 来执行此操作？

Answer 1

如果 SendEmailTask​​ 确实是一个 Runnable，则无法将它们的列表传递给 ExecutorService.invokeAll，您需要一个转换。执行此操作所需的代码与使用 CompletableFuture 执行此操作的代码没有显着差异:

    ExecutorService es = …

    List<Future<Object>> list = es.invokeAll(emails.stream()
        .map(s -> Executors.callable(new SendEmailTask(s)))
        .collect(Collectors.toList()));

    List<Future<Void>> list = emails.stream()
        .map(s -> CompletableFuture.runAsync(new SendEmailTask(s)))
        .collect(Collectors.toList());

如果这些 future 没有返回任何结果，而您只是想等待完成，则可以使用

CompletableFuture<?> f = CompletableFuture.allOf(emails.stream()
    .map(s -> CompletableFuture.runAsync(new SendEmailTask(s)))
    .toArray(CompletableFuture<?>[]::new));

CompletableFuture 将在所有作业完成后完成，如果任何任务失败，它将异常完成。但是，如果多个任务失败，您将只能检查其中一个异常。