reduce(BinaryOperator)返回Optional,用于非空流的聚合;2. reduce(identity, accumulator)提供初始值,避免空值问题;3. reduce(U, BiFunction, BinaryOperator)支持类型转换与并行处理,适用于复杂场景。

Java Stream 的 reduce 方法用于对流中的元素进行聚合操作,将多个元素合并成一个结果。它适用于求和、拼接字符串、查找最值等场景。reduce 有三种常见用法,分别对应不同的参数组合。
1. reduce(BinaryOperator accumulator)
这种形式没有初始值,返回的是 Optional 类型,因为流可能为空。accumulator 是一个函数式接口,接收两个同类型参数并返回相同类型的值。例如,对整数流求和:
List numbers = Arrays.asList(1, 2, 3, 4, 5);
Optional sum = numbers.stream().reduce((a, b) -> a + b);
sum.ifPresent(System.out::println); // 输出 15
如果流为空,Optional 将为空值,需注意空指针风险。
2. reduce(T identity, BinaryOperator accumulator)
提供一个初始值(identity),即使流为空也能返回该初始值,结果类型为 T。常用于明确起始状态的聚合,比如从 0 开始累加:
int sum = numbers.stream().reduce(0, (a, b) -> a + b); // 输出 15
identity 必须满足结合律,并且作为单位元,如加法中用 0,乘法中用 1。
3. reduce(U identity, BiFunction accumulator, BinaryOperator combiner)
这是并行流中使用的三参数版本,支持不同类型的输入和输出。适用于复杂聚合,比如将数字列表转为字符串拼接:
立即学习“Java免费学习笔记(深入)”;
List nums = Arrays.asList(1, 2, 3);
String result = nums.stream().reduce(
"", // 初始值
(str, n) -> str + n, // 累加器:字符串拼接
(s1, s2) -> s1 + s2 // 合并器:并行时合并各段
);
System.out.println(result); // 输出 "123"
这个版本在串行流中也能工作,但通常用于并行流以保证线程安全和正确合并。
使用 reduce 时要注意操作的结合性,避免副作用。对于简单聚合如求和、最大值,也可以考虑使用 mapToInt 等专用方法提高性能。
基本上就这些,掌握这三种 reduce 形式就能应对大多数聚合需求了。










