管理具有多个结果的 Java 8 流的最佳实践是什么

Question

当我想从迭代中获得多个结果时，如何使用流处理 Java 8 中的 forEach。当然，在流 forEach 操作中调用 List.add 方法不是一种选择……您将如何使用 Java 8 流重写此代码？

additionalWebsitesList = Lists.newArrayList();
String additionalWebistesCsv = "";
for (String website : additionalWebsites) {
    WebsiteModel websiteModel = getWebsiteModel(website);

    //How this can be processed via Stream???
    additionalWebsitesList.add(websiteModel);
    areaModels.addAll(websiteModel.getAreas());
    additionalWebistesCsv += websiteModel.getId();
}

Answer 1

使用流执行此类操作的方法是使用自定义收集器。假设我们定义了以下类：

public class Results {
    private final List<WebsiteModel> additionalWebsitesList = new ArrayList<>();
    private final List<AreaModel> areaModels = new ArrayList<>();
    private final StringBuilder additionalWebsitesCsv = new StringBuilder();

    public void accumulate(WebsiteModel websiteModel) {
        additionalWebsitesList.add(websiteModel);
        areaModels.addAll(websiteModel.getAreas());
        additionalWebsitesCsv.append(websiteModel.getId());
    }

    public void combine(Results another) {
        additionalWebsitesList.addAll(another.additionalWebsitesList);
        areaModels.addAll(another.areaModels);
        additionalWebsitesCsv.append(another.additionalWebsitesCsv);
    }

    public List<WebsiteModel> getAdditionalWebsitesList() {
        return additionalWebsitesList;
    }

    public List<AreaModel> getAreaModels() {
        return areaModels;
    }

    public String getAdditionalWebsitesCsv() {
        return additionalWebsitesCsv.toString();
    }
}

有了这个Results 类，您就可以收集结果了：

Results results = additionalWebsites.stream()
    .map(this::getWebsiteModel)
    .collect(Results::new, Results::accumulate, Results::combine);

这使用Stream.collect 方法。第一个参数是Supplier，它创建可变对象，流的元素将通过第二个参数中提供的累加器累积到该对象中。第三个参数是一个合并，如果流是并行的，它将只用于合并部分结果。

Answer 2

管理多个 Java 8 流的最佳实践是什么？ 结果

当然在流forEach操作中调用List.add方法不是 一个选项。

最佳做法不是强迫您使用流，因为用例不合适。
Stream 接口 javadoc 将自己描述为：

支持顺序和并行聚合的元素序列 操作。

Stream 操作返回自己的类型元素序列。
所以Streamcollects 最终会根据元素序列的类型返回一种单一的东西：单一或集合。
例如，我们可以收集 Foo 的 List 的 Foo 的 Map 的 Foo 由 Integer 键索引，等等...
Stream 收集不是设计的收集不同的自定义事物，例如 Foo 的 List + Bar 的 List + Bar 的计数 + Foo。

正如@Eugene 强调的那样，Streams 还提供了一种获取IntSummaryStatistics 的方法，IntSummaryStatistics 是一组事物：最小、最大、总和和平均值的公共聚合。 但是我们不应该认为它最终收集了一个东西：统计数据吗？

所以你有三种方法：

• 将Stream 放在一边以供您的用例使用，并保留for 循环。

• 使用多个流：您要收集的自定义事物的一个流。

• 使用带有自定义收集器的单个流。

在任何情况下我都不会使用第二种方式，因为它会产生比实际代码更不可读和更直接的代码。

关于 Federico Peralta Schaffner 的回答说明的最后一种方式（自定义收集器）。它更直，并且可以从流并行中受益。所以这是一个值得考虑的选择。
但它也需要更多的样板代码，并且需要更多的间接阅读来理解实际逻辑。
所以我认为我只会在两种情况下引入自定义收集器：

• 收集器被重复使用。
• 我们希望从流并行中受益并且我们有大量的元素需要处理（Federico Peralta Schaffner 在其comment 中对此进行了很好的解释，谢谢）。

在任何其他情况下，我都会保留for 循环。

Answer 3

作为 Java 8 流的代码：

additionalWebsitesList = additionalWebsites.stream()
        .map(this::getWebsiteModel)
        .collect(Collectors.toList());
areaModels = additionalWebsites.stream()
        .flatMap(w -> getWebsiteModel(w).getAreas().stream())
        .collect(Collectors.toList());
String additionalWebistesCsv = additionalWebsites.stream()
        .map(this::getWebsiteModel)
        .map(WebsiteModel::getId)
        .collect(Collectors.joining());