java stream自定义collector支持跨线程合并的关键是正确实现线程安全、满足结合律且不修改入参的combiner方法，并可选声明concurrent和unordered特性。
Java Stream 的自定义 Collector 要支持跨线程合并（即并行流中多个线程各自收集局部结果后，最终合并为一个结果），关键在于正确实现 Collector 的 combiner 方法，并确保其线程安全、满足结合律（associative）且能处理空/初始状态。
combiner 必须是无副作用、可任意顺序调用的纯合并逻辑
并行流会将数据分片，每个线程独立执行 accumulator 得到子结果（如部分 Map、List 或自定义容器），再由 combiner 合并这些子结果。该方法必须：
- 接收两个同类型的中间结果（不能假设谁先谁后），返回合并后的新结果；
- 不修改任一入参（避免竞态），推荐创建新对象或使用线程安全容器；
- 满足结合律：
combiner(combiner(a,b),c) == combiner(a, combiner(b,c))； - 能处理任一参数为“空结果”（如
supplier.get()的初始值）的情况。
典型安全实现方式：用不可变结构或线程安全容器
以“统计各字符串长度出现频次”为例，目标是 Map<integer long></integer>：
❌ 错误写法（直接修改入参）：
combiner: (map1, map2) -> { map1.putAll(map2); return map1; } // 竞态风险，违反不可变原则
✅ 推荐写法（创建新 Map）：
Java JDK 25 来自 OpenJDK 官方归档，版本为 JDK 25，本条下载地址已指向官方 Windows x64 zip 安装包直链，适合调试旧项目或兼容旧版 Java 运行环境。
combiner: (map1, map2) -> {
Map<integer long> merged = new HashMap(map1);
map2.forEach((k, v) -> merged.merge(k, v, Long::sum));
return merged;
}</integer>
✅ 更高效写法（用 ConcurrentHashMap + compute，适合大数据量）：
combiner: (map1, map2) -> {
map2.forEach((k, v) -> map1.compute(k, (key, old) -> old == null ? v : old + v));
return map1;
}
注意：此时 supplier 应返回 new ConcurrentHashMap()，且 map1 和 map2 都是并发容器实例，compute 是原子操作。
characteristics 中声明 CONCURRENT 和 UNORDERED（按需）
若 collector 内部使用了线程安全容器（如 ConcurrentHashMap、CopyOnWriteArrayList），且 combiner 可安全并发调用，可在 characteristics() 返回中添加：
-
Collector.Characteristics.CONCURRENT：告知 Stream 框架该 collector 支持并发累积（即多个线程可同时调用accumulator），此时combiner可能被并发调用； -
Collector.Characteristics.UNORDERED：若结果不依赖元素原始顺序（如统计、求和），可加此项提升并行效率。
⚠️ 注意：CONCURRENT 与 UNORDERED 不是必须的，但正确声明能让框架更高效调度。未声明 CONCURRENT 时，即使 combiner 安全，框架仍可能串行合并子结果。
完整示例：线程安全的频次统计 Collector
Collector<string map long>, Map<integer long>> lengthFreqCollector =
Collector.of(
ConcurrentHashMap::new,
(map, str) -> map.compute(str.length(), (k, v) -> v == null ? 1L : v + 1),
(map1, map2) -> {
map2.forEach((len, cnt) -> map1.compute(len, (k, v) -> v == null ? cnt : v + cnt));
return map1;
},
Collections::unmodifiableMap,
Collector.Characteristics.CONCURRENT,
Collector.Characteristics.UNORDERED
);
// 使用
Map<integer long> result = list.parallelStream()
.collect(lengthFreqCollector);
</integer></integer></string>
这个 collector 在并行流中能安全跨线程累积和合并，无需额外同步。
Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南
