Collectors.toConcurrentMap能保证线程安全，因其使用ConcurrentHashMap并采用分段原子操作（如merge、putIfAbsent）合并各线程局部映射，键冲突由mergeFunction处理；必需参数为keyMapper、valueMapper和mergeFunction。
在并行流中直接使用 Collectors.toMap 会抛出 ConcurrentModificationException，因为其底层依赖非线程安全的 HashMap。而 Collectors.toConcurrentMap 是专为并发收集设计的收集器，它内部使用 ConcurrentHashMap，天然支持多线程写入，无需额外同步。
为什么 toConcurrentMap 能保证线程安全
它不依赖单个共享 map 的并发控制（如加锁），而是让每个线程先构建自己的局部映射，再通过 ConcurrentHashMap 的原子方法（如 merge、putIfAbsent）合并结果。键冲突时由你提供的 mergeFunction 决定如何处理，避免竞态。
基本用法与必需参数
该收集器有三个必填参数：
-
keyMapper：定义键的函数（如
Person::getId） -
valueMapper：定义值的函数（如
Person::getName） -
mergeFunction：键重复时的解决策略（如
(oldVal, newVal) -> oldVal保留旧值）
示例：
List<Person> people = Arrays.asList(...);ConcurrentMap<Long, String> idToName = people.parallelStream()
.collect(Collectors.toConcurrentMap(
Person::getId,
Person::getName,
(oldVal, newVal) -> oldVal // 冲突时保留第一个 ));
可选参数：自定义 Map 工厂与并发级别
第四个参数是 mapFactory，允许指定具体实现（如 ConcurrentHashMap::new 或带初始容量/并发级别的构造）；第五个参数是 concurrencyLevel，用于预估并发线程数，影响分段锁数量（默认为 16）。合理设置可减少争用：
- 若已知最多 8 个线程参与，可传
8提升性能 - 工厂函数可传
() -> new ConcurrentHashMap<>(1024, 0.75f, 8)
常见陷阱与注意事项
虽然收集过程线程安全，但仍有几点必须注意：
- 输入流中的元素本身不应被多个线程同时修改（源数据需不可变或已同步）
-
mergeFunction必须是无副作用的纯函数；若抛异常，整个收集会失败 - 返回的是
ConcurrentMap，不是普通Map，某些操作语义不同（如computeIfAbsent是原子的） - 不保证遍历顺序，也不提供强一致性迭代器
