异步运行列表中的所有元素（未知大小）

Question

我正在尝试运行异步代码块的列表。我在旧线程中找到了一些帮助。不一致，向我展示并非所有异步结果都按预期完成。

在此示例代码中，我准备了list＆lt; pountableFuture＆lt; list＆lt; integer＆gt;＆gt;＆gt;。该列表包含一堆我想一次收集的期货，而无需一次等待。每个异步块都将当前整数列表复制到新列表中。

        List<CompletableFuture<List<Integer>>> futureList = new ArrayList<>();
        List<Integer> ints = new ArrayList<>();
        for (int i=0; i<50; i++) {
            ints.add(Integer.valueOf(i));
            if (ints.size() < 5) {
                continue;
            }
            System.out.println(String.format("Input ints: %s", ints));
            CompletableFuture<List<Integer>> future =
                CompletableFuture.supplyAsync(
                    () -> {
                        return new ArrayList<>(ints);
                    });
            futureList.add(future);
            ints.clear();
        }

输出是

Input ints: [0, 1, 2, 3, 4]
Input ints: [5, 6, 7, 8, 9]
Input ints: [10, 11, 12, 13, 14]
Input ints: [15, 16, 17, 18, 19]
Input ints: [20, 21, 22, 23, 24]
Input ints: [25, 26, 27, 28, 29]
Input ints: [30, 31, 32, 33, 34]
Input ints: [35, 36, 37, 38, 39]
Input ints: [40, 41, 42, 43, 44]
Input ints: [45, 46, 47, 48, 49]

接下来的预期，我想收集每个未来的结果。代码是

        try {
            CompletableFuture<List<List<Integer>>> allInts = CompletableFuture
                .allOf(futureList.toArray(new CompletableFuture[0]))
                .thenApply(v ->
                    futureList.stream().map(CompletableFuture::join).collect(Collectors.toList())
                );
            System.out.println(String.format("Output ints: %s", allInts.get()));
        } catch (Exception e) {
            throw new RuntimeException(e);
        }

输出不一致。有时，没有一个INT列表出现，有时会出现其中一些。示例结果：

Output ints: [[15, 16, 17, 18, 19], [25, 26, 27, 28, 29], [15, 16, 17, 18, 19], [15, 16, 17, 18, 19], [25, 26, 27, 28, 29], [30, 31, 32, 33, 34], [35, 36, 37, 38, 39], [40, 41, 42, 43, 44], [45, 46, 47, 48, 49], []]
------------
Output ints: [[10, 11, 12, 13, 14], [20, 21, 22, 23, 24], [10, 11, 12, 13, 14], [20, 21, 22], [25, 26, 27, 28, 29], [30, 31, 32, 33, 34], [35, 36, 37, 38, 39], [40, 41, 42, 43, 44], [45, 46, 47, 48, 49], []]
------------
Output ints: [[10, 11, 12, 13, 14], [10, 11, 12, 13, 14], [10, 11, 12, 13, 14], [35, 36, 37, 38, 39], [], [], [], [], [], []]

很明显，即使我在.alof（）.allof（）结果上运行.thenapply（），也不是所有的期货正在完成。我怀疑.allof（）输入不正确，但我不确定。任何帮助都会很棒。

Answer 1

您的问题是您在所有期货中使用物理上相同的列表，因此取决于未来执行的时间 - 它将看到不同的数组状态，您需要创建单独的副本，例如：

final List<Integer> finalInts = ints.stream().toList();
System.out.println(String.format("Input ints: %s", finalInts));
CompletableFuture<List<Integer>> future =
        CompletableFuture.supplyAsync(
                () -> {
                    return finalInts;
                });