如何在并行流上使用javamapreduce组合器

Question

我有这样的java代码获取字符串（请求）获取http响应-->将其与保存在内存中的旧响应进行比较。

我想在Result对象上收集n个比较结果

并且最终我想要将m个报告对象聚合为一个对象。

我有这个代码

但我不确定我是否在做第二个功能

我应该每次创建新报告吗？

该机制是如何工作的？

        Report report = requestsList
                .parallelStream()
                .map(request ->
                                getResponse(request, e2EResultLongBL, e2EResultLongFresh)
                )
                .map(response -> compareToBl(response, e2EResultLongBL))
                .reduce(null,
                        (sumReport, compare2) ->
                        {
                            if (sumReport == null)
                            {
                                sumReport = new Report();
                            }
                            sumReport.add(compare2);
                            return  sumReport;
                        },
                        (report1, report2) ->
                        {
                            Report report3 = new Report();
                            report3.add(report2);
                            return report3;
                        });

编辑

我尝试过"收集"而不是"减少"

我得到了这个错误：

Error:(174, 21) java: no suitable method found for collect(<nulltype>,(sumReport[...]rt; },(report1,r[...]t3; })
    method java.util.stream.Stream.<R>collect(java.util.function.Supplier<R>,java.util.function.BiConsumer<R,? super com.waze.routing.automation.dataModel.ComparisonResult>,java.util.function.BiConsumer<R,R>) is not applicable
      (cannot infer type-variable(s) R
        (argument mismatch; unexpected return value))
    method java.util.stream.Stream.<R,A>collect(java.util.stream.Collector<? super com.waze.routing.automation.dataModel.ComparisonResult,A,R>) is not applicable
      (cannot infer type-variable(s) R,A
        (actual and formal argument lists differ in length))

Answer 1

您肯定想要一个收集器。您将为每个并行执行创建一个报告，将单个比较添加到报告中，然后将这些报告与最终函数合并。

无需在组合器上创建新的报告。只需将2加1即可。

.collect(Collector.of(
    () -> new Report(),
    (report, compare2) -> {
       report.add(compare2);
       return report;
    },
    (report1, report2) -> {
       report1.add(report2);
       return report1;
    });

此外，如果您想让代码更干净，请使用添加函数return this;。您将能够用函数引用替换lambda。

.collect(Collector.of(Report::new, Report::add, Report::add));