使用流在列表列表中查找对象[重复]

Question

我正在尝试编写一个方法，该方法可以在列表列表中找到对象的索引并利用并行性。这是我的代码。

// returns [i, j] where lists.get(i).get(j) equals o, or null if o is not present.
public static int[] indices(List<? extends List<?>> lists, Object o) {
    return IntStream.range(0, lists.size())
                    .boxed()
                    .flatMap(i -> IntStream.range(0, lists.get(i).size()).mapToObj(j -> new int[]{i, j}))
                    .parallel()
                    .filter(a -> {
                        System.out.println(Arrays.toString(a));     // For testing only
                        return Objects.equals(o, lists.get(a[0]).get(a[1]));
                    })
                    .findAny()
                    .orElse(null);
}

当我运行以下代码时

List<List<String>> lists = Arrays.asList(
        Arrays.asList("A", "B", "C"),
        Arrays.asList("D", "E", "F", "G"),
        Arrays.asList("H", "I"),
        Collections.nCopies(5, "J")
);
System.out.println("Indices are " + Arrays.toString(indices(lists, "J")));

输出类似于

[0, 0]
[0, 1]
[0, 2]
[3, 0]
[3, 1]
[3, 2]
[3, 3]
[2, 0]
[3, 4]
[1, 0]
[1, 1]
[2, 1]
[1, 2]
[1, 3]
Indices are [3, 0]

换句话说，即使在找到对象之后，搜索仍在继续。findAny不应该是短路操作吗？我错过了什么？此外，在迭代列表或锯齿数组时，利用并行性的最佳方法是什么？

编辑

按照@Sotirios回答中的想法，我得到了以下输出

Thread[ForkJoinPool.commonPool-worker-3,5,main] [3, 0]
Thread[main,5,main] [2, 0]
Thread[main,5,main] [2, 1]
Thread[ForkJoinPool.commonPool-worker-1,5,main] [1, 0]
Thread[ForkJoinPool.commonPool-worker-1,5,main] [1, 1]
Thread[ForkJoinPool.commonPool-worker-1,5,main] [1, 2]
Thread[ForkJoinPool.commonPool-worker-1,5,main] [1, 3]
Thread[main,5,main] [0, 0]
Thread[main,5,main] [0, 1]
Thread[ForkJoinPool.commonPool-worker-3,5,main] [3, 1]
Thread[main,5,main] [0, 2]
Thread[ForkJoinPool.commonPool-worker-3,5,main] [3, 2]
Thread[ForkJoinPool.commonPool-worker-3,5,main] [3, 3]
Thread[ForkJoinPool.commonPool-worker-3,5,main] [3, 4]
Indices are [3, 0]

请注意

Thread[ForkJoinPool.commonPool-worker-3,5,main]

即使找到答案也继续搜索。

Answer 1

匿名用户

这并不是说它继续，而是它已经调度了各种线程来尝试找到结果，并将等到这些线程完成后再返回结果。

换句话说，< code>findAny终端操作将把“搜索”任务提交给许多线程。这些任务只是应用< code>filter 谓词并在返回< code>true时返回。< code>findAny，大概是等待其中一个返回值。它没有办法真正取消它已经提交的任何东西，而且看起来这个实现将会阻塞，直到整个批处理返回。它只能停止提交任何未来批次。

您可以通过记录当前线程来验证这一点：

System.out.println(Thread.currentThread() + " " + Arrays.toString(a)); // For testing only

Answer 2

至于“为什么会这样实现”。问题深深地在于Stream API实现。平地图主体经常创建一个带有一些中间操作的流（如.平地图（list-

Answer 3

短路操作不能保证只拉动产生其结果所需的少量元件。他们可以这样做，但不是必须的。

flatMap 的当前实现使得它始终将子流的全部内容推送到下游。因此，即使您的流不是并行的，您也可以看到流中流的元素比满足 findAny 所需的元素多。