294. Java Stream API - 对流进行归约

🎯 什么是归约（Reduction）？

在Java Stream API中，所谓的归约操作，其实就像 SQL 中的聚合操作 —— 比如SUM(),MAX()等。我们通过一个终端操作（Terminal Operation）来将流中的多个元素聚合成一个结果。

✅ 什么是终端操作？

终端操作会触发整个流的执行，常见的包括：

• collect()（如：collect(Collectors.toList())）
• reduce()（本节主角）
• forEach()
• count()
• anyMatch(),allMatch(), 等

🔔 注意事项：

1. 没有终端操作的流不会执行任何处理！
   • 如果你看到一个只调用了map()或filter()但没有终端操作的流，那就是个 bug。
2. 每个 Stream 实例只能执行一次终端操作！
   • 流一旦执行终端操作，就会“关闭”，不能再使用，否则会抛出IllegalStateException。

🧠 使用BinaryOperator对流进行归约

Java中reduce()方法的核心，就是使用一个二元操作符（BinaryOperator）将两个元素合并成一个，不断迭代直到只剩一个值。

🧪 示例一：经典求和

我们先用传统 for 循环来实现整数列表求和：

List<Integer>ints=List.of(3,6,2,1);intsum=ints.get(0);for(inti=1;i<ints.size();i++){sum+=ints.get(i);}System.out.println("sum = "+sum);

🟢 输出：

sum=12

🔍 这个过程就是不断把前面计算的“部分和”与下一个元素相加。

🔁 示例二：使用 BinaryOperator 改写

我们可以将“加法”逻辑抽象成一个BinaryOperator：

List<Integer>ints=List.of(3,6,2,1);BinaryOperator<Integer>sum=(a,b)->a+b;intresult=ints.get(0);for(inti=1;i<ints.size();i++){result=sum.apply(result,ints.get(i));}System.out.println("sum = "+result);

🟢 输出：

sum=12

🎯 好处：只需要更换BinaryOperator，就能实现其他聚合操作！

🧪 示例三：计算最大值（MAX）

只需将 BinaryOperator 换成一个“取较大值”的函数：

List<Integer>ints=List.of(3,6,2,1);BinaryOperator<Integer>max=(a,b)->a>b?a:b;intresult=ints.get(0);for(inti=1;i<ints.size();i++){result=max.apply(result,ints.get(i));}System.out.println("max = "+result);

🟢 输出：

max=6

☕ Stream API 中的 reduce() 方法

现在让我们用Stream 的 reduce() 方法来实现相同逻辑。reduce()有多个重载版本，这里我们使用最基础的一种：

List<Integer>ints=List.of(3,6,2,1);Optional<Integer>sum=ints.stream().reduce((a,b)->a+b);sum.ifPresent(s->System.out.println("sum = "+s));

🟢 输出：

sum=12

🔎reduce()返回的是Optional<T>，因为当流为空时，没有结果。

🧪 示例四：带初始值的 reduce（避免 Optional）

List<Integer>ints=List.of(3,6,2,1);intsum=ints.stream().reduce(0,(a,b)->a+b);System.out.println("sum = "+sum);

🟢 输出：

sum=12

🎯 传入初始值后，reduce()会从这个值开始进行归约，并返回确定的类型（非 Optional）。

📌 小结

🧠 延伸思考

• reduce()可以用于更多复杂的聚合计算，例如拼接字符串、合并集合等。
• 在并行流中（parallelStream()），reduce()的初始值需要满足结合律，以确保并发结果一致。