合并地图 Java 8流

Question

我想将两个Map与JAVA 8 Stream合并：

Map<String, List<String>> mapGlobal = new HashMap<String, List<String>>();
Map<String, List<String>> mapAdded = new HashMap<String, List<String>>();

我尝试使用此实现：

mapGlobal = Stream.of(mapGlobal, mapAdded)
                .flatMap(m -> m.entrySet().stream())
                .collect(Collectors.groupingBy(Map.Entry::getKey,
                        Collectors.mapping(Map.Entry::getValue,        
                                           Collectors.toList())
                ));

但是，此实现只会产生如下结果：

Map<String, List<Object>>

如果中没有包含一个键mapGlobal，则会将其作为新键添加到相应的String列表中。如果键在mapGlobal和中重复mapAdded，则两个值列表将被合并为：A = {1, 3, 5, 7}，B = {1, 2, 4, 6}然后是A ∪ B = {1, 2, 3, 4, 5, 6, 7}。

Answer 1

您可以通过遍历中的所有条目mapAdded并将它们合并到中来实现此目的mapGlobal。

下面mapAdded通过调用forEach(action)操作消耗每个条目的键和值的位置来遍历的条目。对于每个条目，我们叫merge(key, value, remappingFunction)上mapGlobal：这将要么创建键下的条目k和值v如果该键不存在，或者它会调用给定的重新映射功能，如果他们已经存在。此函数将2个列表合并，在这种情况下，首先将其添加到中TreeSet以确保元素唯一和排序，然后将其转换回列表：

mapAdded.forEach((k, v) -> mapGlobal.merge(k, v, (v1, v2) -> {
    Set<String> set = new TreeSet<>(v1);
    set.addAll(v2);
    return new ArrayList<>(set);
}));

如果您想并行运行它，可以通过获取entrySet()并调用parallelStream()它来创建一个Stream管道。但随后，您需要确保使用支持并发的映射mapGlobal，例如ConcurrentHashMap。

ConcurrentMap<String, List<String>> mapGlobal = new ConcurrentHashMap<>();
// ...
mapAdded.entrySet().parallelStream().forEach(e -> mapGlobal.merge(e.getKey(), e.getValue(), (v1, v2) -> {
    Set<String> set = new TreeSet<>(v1);
    set.addAll(v2);
    return new ArrayList<>(set);
}));