如何在forEach中执行操作并将其传递给Java流中的groupingBy

Question

我想根据某一个决定来划分我的一个列表。我也有一个地图存储这些决定。目前，我正在更新流本身中的决定。我觉得这不是一个好的做法，因为我正在使用collect来执行其他操作，而不是计算分组标准。我有的另一个选择是再次遍历流，并使用forEach更新映射，但这意味着我将使用getFinalDecision两次。有没有更好的办法？有没有一种方法可以在forEach中执行getFinalDecision并将其传递给GroupingBy？

val test = myList.stream().collect(groupingBy(t -> {
      A a = my_map.get(t.getSomething());
      A finalDecision = getFinalDecision(t.getSomeOtherThing(), a);
      my_map.put(t.getSomething(), finalDecision);
      return finalDecision;
}));

Answer 1

我不确定，但看起来你实际上想做的更像是

Map<X,Y> result = myList.stream()
    .collect(groupingBy(t -> t.getSomething(),
         reducing(null, t -> t.getSomeOtherThing(), (a,b) -> getFinalDecision(b,a) )));

其中，x是GetSomething()的返回类型，y是GetSomething()的返回类型。GetFinalDecision(…)。当然，它也起作用，如果x和y是同一类型。

这将模仿原始代码中初始为空的映射的行为，导致null作为第二个参数传递给GetFinalDecision以获得每个不同键的第一次出现。然后，第二个参数将是之前对该键的GetFinalDecision求值的结果。

Map<X,Y> result = myList.stream()
    .collect(groupingBy(t -> t.getSomething(), mapping(t -> t.getSomeOtherThing(),
        collectingAndThen(reducing((a,b) -> getFinalDecision(a,b)), Optional::get))));

该值最初将是每个不同键的第一个GetSomeOtherthing()调用的结果，并且只有在该键出现一个以上的情况下才会调用GetFinalDecision。因此，第二个参数不会是null，除非GetFinalDecision本身在以前的计算中返回null。