reduce方法用于将流元素归约为单个结果,支持求和、拼接等操作。1. 无初始值时返回Optional,避免空流异常;2. 提供初始值确保非Optional结果,适用于默认值场景;3. 并行流专用版本含合并器,保证多线程结果正确合并,需满足结合律。

在Java中,Stream.reduce 是一种强大的归约操作,用于将流中的元素合并成一个单一的结果。它适用于求和、拼接字符串、查找最大值等场景。reduce 方法有三种常见重载形式,下面分别介绍其用法和实际示例。
1. reduce(BinaryOperator accumulator)
这种形式使用一个 BinaryOperator 函数接口,接收两个相同类型的参数并返回同类型结果。注意:如果流为空,会返回 Optional 类型以避免异常。示例:计算整数流的总和
ListOptional
sum.ifPresent(System.out::println); // 输出 15
这里 (a, b) -> a + b 是累加器函数,每次将两个元素相加,逐步归约为最终结果。
2. reduce(identity, BinaryOperator accumulator)
提供一个初始值(identity),即使流为空也能返回该类型的值,不再返回 Optional。示例:带默认值的字符串拼接
立即学习“Java免费学习笔记(深入)”;
ListString result = words.stream().reduce("", String::concat);
System.out.println(result); // 输出 "Hello World"
初始值为 "",每个元素依次与当前结果拼接。String::concat 等价于 (a, b) -> a + b。
3. reduce(identity, BiFunction accumulator, BinaryOperator combiner)
这个版本主要用于并行流,其中:- identity:初始值
- accumulator:如何将流中每个元素合并到中间结果(BiFunction)
- combiner:如何合并多个线程的中间结果(BinaryOperator)
示例:并行流中累加整数(自定义类型转换)
ListInteger total = nums.parallelStream()
.reduce(0, (sum, item) -> sum + item, Integer::sum);
System.out.println(total); // 输出 10
虽然此例中效果与第二种相同,但在处理复杂对象或自定义逻辑时,第三个参数能确保并行环境下正确合并结果。
需要注意的是,第三种形式的 identity 在并行处理中必须满足“可结合性”,否则可能出现错误结果。比如不能传入 ArrayList::add 这类破坏性操作作为 accumulator。
基本上就这些。reduce 的核心是通过函数式方式累积数据,写法简洁且语义清晰,适合替代传统循环进行聚合操作。









