reduce(BinaryOperator)返回Optional,用于非空流的聚合;2. reduce(identity, accumulator)提供初始值,避免空值问题;3. reduce(U, BiFunction, BinaryOperator)支持类型转换与并行处理,适用于复杂场景。
Java Stream 的 reduce 方法用于对流中的元素进行聚合操作,将多个元素合并成一个结果。它适用于求和、拼接字符串、查找最值等场景。reduce 有三种常见用法,分别对应不同的参数组合。
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 将为空值,需注意空指针风险。
常用于明确起始状态的聚合,比如从 0 开始累加:
int sum = numbers.stream().reduce(0, (a, b) -> a + b); // 输出 15
identity 必须满足结合律,并且作为单位元,如加法中用 0,乘法中用 1。
适用于复杂聚合,比如将数字列表转为字符串拼接:
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 形式就能应对大多数聚合需求了。