假设我有以下片段:(未来是可调用任务的结果)
List<Map<String, List<Offset>>> results = new ArrayList<>();
for (Future<Map<String, List<Offset>>> future : listFutures) {
Map<String, List<Offset>> mapResult = future.get();
results.add(mapResult);
}
我想将所有"Map<String, List<Offset>>"
汇总到所有flatMap
的Futures
,用例将是地图之间的重复键,在这种情况下我需要将值添加到List<Offset>
列表中
我预计在flatMap之后,有"Map<String, List<Offset>>"
的结果
P.S
我看到了一些例子,但他们在迭代期间没有说话。
Stream.concat(map1.entrySet().stream(), map2.entrySet().stream())
.collect(Collectors.toMap(
entry -> entry.getKey(),
entry -> entry.getValue()
)
);
有什么建议吗?
如果我把一切都搞定了......
listFutures.stream()
.map(x -> {
try {
return x.get();
} catch (InterruptedException | ExecutionException e) {
throw new RuntimeException(e);
}
})
.flatMap(x -> x.entrySet().stream())
.collect(Collectors.toMap(
Entry::getKey,
Entry::getValue,
(left, right) -> {
left.addAll(right);
return left;
}));
并且可能是一种更简单的方法:
for (Future<Map<String, List<Offset>>> f : listFutures) {
Map<String, List<Offset>> inner = f.get();
for (Entry<String, List<Offset>> e : inner.entrySet()) {
results.merge(e.getKey(), e.getValue(), (left, right) -> {
left.addAll(right);
return left;
});
}
}