用并行流替换嵌套的 for 循环 - Java

Question

我正在努力提高性能至关重要的程序的速度。目前它无法处理大型数据集。有很多嵌套的 for 循环，所以我认为值得尝试并行流。我可以访问高性能集群，因此可能有许多可用内核。 我有以下方法：

public MinSpecSetFamily getMinDomSpecSets() {
        MinSpecSetFamily result = new MinSpecSetFamily();
        ResourceType minRT = this.getFirstEssentialResourceType();
        if (minRT == null || minRT.noSpecies()) {
            System.out.println("Problem in getMinDomSpecSets()");
        }
        for (Species spec : minRT.specList) {
            SpecTree minTree = this.getMinimalConstSpecTreeRootedAt(spec);
            ArrayList<SpecTreeNode> leafList = minTree.getLeaves();
            for (SpecTreeNode leaf : leafList) {
                ArrayList<Species> sp = leaf.getAncestors();
                SpecSet tmpSet = new SpecSet(sp);
                result.addSpecSet(tmpSet);
            }
        }
        return result;
    }

我知道我可以将嵌套的 for 循环转换为并行流，例如：

minRT.specList.parallelStream().flatMap(leaf -> leaflist.parallelStream())

但是，我找不到显示如何处理每个 for 循环中的操作的示例，而且我对它应该如何工作完全没有信心。我非常感谢有关如何转换此方法的一些帮助和解释，以便我也可以将解决方案转换为程序中的其他方法。 谢谢。

Answer 1

这是一种方法（希望我没有错别字）：

MinSpecSetFamily result =
    minRT.specList
         .parallelStream()
         .flatMap(spec -> getMinimalConstSpecTreeRootedAt(spec).getLeaves().stream())
         .map(leaf -> new SpecSet(leaf.getAncestors()))
         .reduce(new MinSpecSetFamily (),
                 (fam,set)-> {
                     fam.addSpecSet(set);
                     return fam;
                 },
                 (f1, f2) -> new MinSpecSetFamily(f1, f2));

编辑：按照 Holger 的评论，您应该使用 collect 而不是 reduce：

MinSpecSetFamily result =
    minRT.specList
         .parallelStream()
         .flatMap(spec -> getMinimalConstSpecTreeRootedAt(spec).getLeaves().stream())
         .map(leaf -> new SpecSet(leaf.getAncestors()))
         .collect(MinSpecSetFamily::new,MinSpecSetFamily::addSpecSet,MinSpecSetFamily::add);