Java中的嵌套并行流执行-findAny（）随机失败

Question

        AllDirectedPaths<Vertex, Edge> allDirectedPaths = new AllDirectedPaths<>(graph);
        List<GraphPath<Vertex, Edge>> paths = allDirectedPaths.getAllPaths(entry, exit, true, null);


        return paths.parallelStream().map(path -> path.getEdgeList().parallelStream()
                .map(edge -> {
                    Vertex source = edge.getSource();
                    Vertex target = edge.getTarget();

                    if (source.containsInstruction(method, instructionIndex)) {
                        return source;
                    } else if (target.containsInstruction(method, instructionIndex)) {
                        return target;
                    } else {
                        return null;
                    }
                }).filter(Objects::nonNull)).findAny().flatMap(Stream::findAny)
                .orElseThrow(() -> new IllegalArgumentException("Given trace refers to no vertex in graph!"));

将“find any（）”流操作放在哪里有关系吗？我应该直接在过滤器操作后放置它吗？还是嵌套的并行流是问题所在？

Answer 1

您应该使用.Flatmap(path->...)并删除.Flatmap(stream::findany)。

您的代码无法工作，因为第一个findany()返回的流始终是非空的，但可能包含null元素。

然后，当通过optional.flatmap（stream：：findany）调用应用第二个findany()时，最后一个查找操作可能返回一个空的optional，其结果是内部流的null元素。

代码应该是这样的：

return paths.stream()
    .flatMap(path -> path.getEdgeList().stream()
        .map(edge -> 
             edge.getSource().containsInstruction(method, instructionIndex) ?
             edge.getSource()                                               :
             edge.getTarget().containsInstruction(method, instructionIndex) ?
             edge.getTarget()                                               :
             null)
        .filter(Objects::nonNull))
    .findAny()
    .orElseThrow(() -> new IllegalArgumentException("whatever"));

注意：为什么是并行流？在您的管道中似乎没有CPU绑定的任务。此外，并行流会产生大量的开销。它们在非常少的场景中很有用，即在流水线上有数万个元素和密集的CPU操作

编辑：正如注释中所建议的，内部流的map和filter操作可以安全地移动到外部流。通过这种方式，可读性得到了提高，并且在性能方面没有差异：

return paths.stream()
    .flatMap(path -> path.getEdgeList().stream())
    .map(edge -> 
         edge.getSource().containsInstruction(method, instructionIndex) ?
         edge.getSource()                                               :
         edge.getTarget().containsInstruction(method, instructionIndex) ?
         edge.getTarget()                                               :
         null)
    .filter(Objects::nonNull)
    .findAny()
    .orElseThrow(() -> new IllegalArgumentException("whatever"));