java - Collectors.toConcurrentMap 和通过 Collectors.toMap 供应商选项将 Map 转换为 ConcurrentHashMap 之间有什么区别？

Question

我想通过 Java 8 Stream 和 Collector 接口(interface)将 Map 转换为 ConcurrentHashMap，然后是我可以使用的两个选项。

第一个:

Map<Integer, String> mb = persons.stream()
                                 .collect(Collectors.toMap(
                                            p -> p.age, 
                                            p -> p.name, 
                                            (name1, name2) -> name1+";"+name2,
                                            ConcurrentHashMap::new));

第二个:

Map<Integer, String> mb1 = persons.stream()
                                  .collect(Collectors.toConcurrentMap(
                                             p -> p.age, 
                                             p -> p.name));

哪个是更好的选择？我应该在什么时候使用每个选项？

Answer 1

它们在处理并行流时是有区别的。

toMap -> 是非并发收集器

toConcurrentMap -> 是一个并发收集器(这个从它们的特性就可以看出)。

区别在于toMap会创建多个中间结果，然后合并在一起(这样的Collector的Supplier会被多次调用)，而toConcurrentMap会创建一个单个结果，每个线程都会向它抛出结果(这样一个收集器的供应商将只被调用一次)

为什么这很重要？这涉及广告订单(如果重要的话)。

toMap 将通过合并多个中间结果(该收集器的 Supplier 和 Combiner 多次调用)以遇到顺序在结果 Map 中插入值

toConcurrentMap 将通过将所有元素放入公共(public)结果容器(本例中为 ConcurrentHashMap)以任何顺序(未定义)收集元素。 Supplier 只被调用一次，Accumulator 被调用多次而 Combiner 永远不会被调用。

这里的小警告是，CONCURRENT 收集器不调用合并:流必须具有 UNORDERED 标志 - 通过 unordered () 显式调用或流源未排序时(例如 Set)。