并行流collect本质是封装“分而治之+合并结果”，通过Supplier（创建线程本地容器）、Accumulator（线程内累加）、Combiner（合并中间结果）三函数保障线程安全与结果一致性。
并行流中的 collect 操作，本质上是把“分而治之 + 合并结果”这个过程封装得既安全又透明。它不像 reduce 那样直接暴露累加逻辑，而是通过 Collector 的三个核心函数——Supplier（造容器）、Accumulator（往里塞元素）、Combiner（合并多个容器）——来显式定义并行归约的合成逻辑。
Collector 的三要素如何对应并行执行阶段
当你调用 parallelStream().collect(...) 时，JVM 会自动按 Fork/Join 分割数据，并为每个子任务分配独立线程：
-
Supplier：每个线程启动时各自调用一次，创建专属的结果容器（比如一个新
ArrayList），避免共享状态和锁竞争 - Accumulator：每个线程在自己的容器上逐个添加处理后的元素，全程无交叉
-
Combiner：所有子任务完成后，将各线程的中间容器两两合并（如
list1.addAll(list2)），最终收敛为单个结果
为什么 Combiner 是并行正确性的关键
Combiner 不是可选项，而是并行模式下必须具备的逻辑。它的作用不是“锦上添花”，而是保障结果一致性：
- 若省略 Combiner（比如手动写
collect(ArrayList::new, ArrayList::add, null)），并行流会直接抛UnsupportedOperationException - Combiner 必须满足结合律：
combine(combine(a,b),c) == combine(a,combine(b,c))，否则合并顺序不同会导致结果错乱 - 常见安全组合：
ArrayList::addAll、HashMap::putAll、StringBuilder::append；不安全例子：LinkedList::addFirst（顺序敏感）
对比 reduce：何时该让 collect 承担合成职责
reduce 的第三个参数（combiner）只适用于“类型不变”的纯归约（如 Integer::sum）；而 collect 的 Combiner 可处理类型转换与结构构建：
- 你要汇总成
Map<string list>></string>？Collectors.groupingBy()内部的 Combiner 自动合并各线程的 Map 实例 - 你要去重并保持插入顺序？
Collectors.toCollection(LinkedHashSet::new)的 Combiner 会调用addAll，而非破坏顺序的putAll - 你自定义 Collector？Combiner 就是你控制“跨线程怎么合”的唯一出口，比如对统计对象做
left.merge(right)
一个可验证的小实验
用 100 个数字跑并行 collect，打印每个线程的中间容器，能直观看到合成过程：
（伪代码示意）List<Integer> result = IntStream.range(1, 101).boxed()<br> .parallel()<br> .collect(<br> () -> { System.out.println("【新容器】Thread: " + Thread.currentThread().getName()); return new ArrayList<Integer>(); },<br> (list, x) -> { list.add(x); System.out.println("【添加】" + x + " → " + list.size() + " 个"); },<br> (l1, l2) -> { System.out.println("【合并】" + l1.size() + " + " + l2.size()); l1.addAll(l2); }<br> );
运行后你会看到多个“【新容器】”，若干“【添加】”，最后几轮“【合并】”——这就是并行归约的真实脉络。
