java - 在保持非阻塞的情况下有序执行许多 CompletableFuture.allof()

Question

我有这种情况，其中有 10 个或更多任务被分为许多组。在这些组内，一切都应该同时运行，但是因为每个组都需要前一组的结果(第一组除外)，我需要以有序的方式运行它们(组内的任务不需要按顺序运行).

任务本身是从数据库中查询数据，然后应用一些转换并将其保存回数据库。

Task 1.1 // This group run first
Task 1.2

Task 2.1 // Waiting results from group 1
Task 2.2
Task 2.3

Task 3.1 // Waiting results from group 2

我想使用 allOf() 列表，迭代它然后为每个 allOf() 显式调用 get() ，但它会阻止我不希望它发生，所以我的问题是，如何按顺序执行许多 allOf() ？甚至可以在这里只使用 CompletableFuture 吗？

Answer 1

当您使用 allOf() 时，它会返回一个 CompletableFuture，只有当所有给定的完成阶段都完成时才会完成。

如果您从返回的 future 中链式调用，则可以保证在传递给 allOf() 的任何完成阶段对 get() 的调用永远不会 block (因为它们已经完成)。

// First group
CompletableFuture<Integer> task11 = CompletableFuture.supplyAsync(() -> 1);
CompletableFuture<Integer> task12 = CompletableFuture.supplyAsync(() -> 42);
CompletableFuture<Integer> task13 = CompletableFuture.supplyAsync(() -> 1729);

// this one will complete after all tasks from the first group complete
CompletableFuture<Void> allFirstTasks = CompletableFuture.allOf(task11, task12, task13);

// Second group will be child tasks from the first group
CompletableFuture<Integer> task21 = allFirstTasks.thenApply(__ ->
        task11.join() + task12.join() + task13.join() // will not block
);

注意:使用 join() 而不是 get() 来避免处理已检查的异常。