Stream.builder()仅用于一次性构建固定、不可变、串行的Stream，不支持动态追加或直接聚合；复杂变量聚合应使用collect()或reduce()。
Stream.builder() 并不用于构建“可变流”或支持后续聚合计算，它只是一个流元素的构造器（builder），作用是逐步添加元素，最终一次性构建一个固定、不可变、串行的 Stream。它不支持动态追加、状态维护、并行累积，更不能替代 reduce 或 collect 实现复杂变量数据的聚合。
如果你的目标是“对复杂变量数据做聚合”，真正该用的是：
✅ 正确路径：用 stream.collect() 或 stream.reduce() 处理复杂聚合
Stream.builder() 只适合这种场景：
你有一组零散、尚未组织的数据（比如从多个条件分支中临时收集的几个对象），想快速凑成一个流进行后续处理。
Stream<String> s = Stream.<String>builder()
.add("apple")
.add("banana")
.add("cherry")
.build(); // 构建完成即固定，不能再 add⚠️ 它不是可变流容器，调用 .build() 后无法再添加元素；也不能直接聚合——必须配合 collect 或 reduce 才能算出结果。
✅ 复杂变量聚合的推荐方式（按场景选）
1. 需要带状态的聚合（如平均值、分组统计、累计标记）
用 collect(Collector) —— 类型安全、可复用、天然支持并发：
// 计算平均年龄（同时维护 sum 和 count）
Double avgAge = users.stream()
.collect(Collectors.averagingDouble(User::getAge));
// 自定义 Collector 做多维统计（如：{maxSalary, minSalary, count}）
Collector<User, ?, Summary> summaryCollector = Collector.of(
() -> new Summary(), // supplier
(acc, u) -> acc.accumulate(u), // accumulator
(a, b) -> a.combine(b), // combiner
acc -> acc // finisher
);
Summary result = users.stream().collect(summaryCollector);2. 需要自定义归约逻辑（如构建树形结构、拼接带分隔符的字符串、合并 Map）
用三参数 reduce(identity, accumulator, combiner)：
// 安全拼接非空字符串（避免 null 导致 NPE）
String joined = list.stream()
.filter(Objects::nonNull)
.reduce("",
(a, b) -> a.isEmpty() ? b : a + ", " + b,
(a, b) -> a.isEmpty() ? b : b.isEmpty() ? a : a + ", " + b
);✅ 关键点：
identity不可变（如""）、accumulator返回新对象（不改a）、combiner满足结合律。
3. 聚合后还需继续链式操作（如 filter → map → collect）
直接走标准流流水线，无需 builder：
List<String> names = users.parallelStream()
.filter(u -> u.getAge() > 18)
.map(User::getName)
.distinct()
.sorted()
.limit(100)
.collect(Collectors.toList());❌ 常见误解与风险
-
Stream.builder().add(...).build()不是“可变流”，也不是“延迟聚合流”——它只是个一次性装配工具。 - 试图用 builder 在循环里反复 add 来模拟“动态流”，会因多次调用
build()创建多个独立流，无法聚合。 - 把
new ArrayList()当作identity传给双参数reduce，在并行流中必然引发线程冲突（资料已明确警告）。
小结：builder 的定位很清晰
| 场景 | 是否适用 Stream.builder()
|
|---|---|
| 临时拼几个已知元素，凑成流做一次过滤/映射 | ✅ 适合 |
| 从数据库、文件、API 分批读取数据并持续聚合 | ❌ 应用 collect 或外部状态 + forEach
|
| 实现实时累加、滑动窗口、带状态计数器 | ❌ 应用 Kafka Streams / Flink / 或自定义 AtomicReference + forEach
|
| 替代 for 循环做复杂业务聚合（如生成报表摘要） | ❌ 优先用 collectingAndThen 或自定义 Collector
|
不复杂但容易忽略：builder 是起点，不是引擎；聚合靠 collect 和 reduce，不是靠“流是否可变”。
