有没有一种优雅的方法可以将地图流减少到一个地图

Question

给定一些地图，是否有一种单行方式将它们的所有条目放入一张地图中？

忽略空值、覆盖条目等问题，我想编码的是：

public static <K, V> Map<K, V> reduce(Map<K, V>... maps) {
    return Arrays.stream(maps)
        .reduce(new HashMap<K, V>(), (a, b) -> a.putAll(b));
}

但这会产生编译错误，因为a.putAll(b) 是void。如果它返回this，它将起作用。

为了解决这个问题，我编写了代码：

public static <K, V> Map<K, V> reduce(Map<K, V>... maps) {
    return Arrays.stream(maps)
        .reduce(new HashMap<K, V>(), (a, b) -> {a.putAll(b); return a;});
}

它可以编译和工作，但它是一个丑陋的 lambda；编码return a; 感觉是多余的。

一种方法是重构一个实用方法：

public static <K, V> Map<K, V> reduce(Map<K, V> a, Map<K, V> b) {
    a.putAll(b);
    return a;
}

清理 lambda：

public static <K, V> Map<K, V> reduce(Map<K, V>... maps) {
    return Arrays.stream(maps)
       .reduce(new HashMap<K, V>(), (a, b) -> reduce(a, b));
}

但现在我有一个可重复使用但有点无用的实用方法。

有没有更优雅的方式来调用累加器上的方法并在 lambda 中返回它？

Answer 1

reduce 的工作原理与

U result = identity;
for (T element : this stream)
    result = accumulator.apply(result, element)
return result;

这意味着代表accumulator.apply 的lambda 需要return 结果（最终或中间结果）。

如果你想避免这种行为，请使用collect，它更像

R result = supplier.get();
for (T element : this stream)
    accumulator.accept(result, element);
return result;

所以表示accumulator.accept的lambda不需要return任何值，而是根据element修改result。

例子：

public static <K, V> Map<K, V> reduce(Map<K, V>... maps) {
    return Arrays.stream(maps)
            .collect(HashMap::new, Map::putAll, Map::putAll);
            //                          ^            ^
            //                          |         collect results from parallel streams
            //                       collect results in single thread
}