本文介绍如何利用 Java 8 Stream 的 reduce 操作高效判断列表中是否存在连续 n 个元素同时满足某条件（例如连续 6 天工时 > 0），避免遍历全部元素，兼顾可读性与短路优化潜力。
本文介绍如何利用 java 8 stream 的 `reduce` 操作高效判断列表中是否存在连续 n 个元素同时满足某条件（例如连续 6 天工时 > 0），避免遍历全部元素，兼顾可读性与短路优化潜力。
在实际业务中，我们常需检测“连续性行为”，比如员工是否连续工作满 6 天（即连续 6 个非零工时值）。Stream.allMatch() 仅适用于全部元素满足条件，无法表达“连续子序列”逻辑；而 anyMatch() 或 findFirst() 也无法直接追踪状态。此时，Stream.reduce() 成为更合适的选择——它允许我们在累积过程中维护一个有状态的计数器。
核心思路是：遍历每个元素，动态维护一个“当前连续满足条件的长度”：
- 若当前元素满足条件（如
num > 0），计数器+1； - 否则重置计数器为
0； - 一旦计数器达到目标值（如
6），即可判定为true。
以下是完整实现：
public static boolean hasConsecutivePositive(List<Integer> hours, int consecutiveDays) {
return hours.stream()
.reduce(0, (count, num) ->
count >= consecutiveDays
? count // 已满足，保持状态，避免无效计算
: (num > 0 ? count + 1 : 0)
) >= consecutiveDays;
}使用示例：
Java Maven Common
下载
Java Maven 项目审查工作流的通用输入处理。当 Java Maven 项目以 ZIP压缩包或 GitLab 仓库 URL 形式提供且需要...时使用。
立即学习“Java免费学习笔记（深入）”；
List<Integer> x = Arrays.asList(0, 0, 0, 6, 0, 7, 9, 0, 0, 8, 9, 0, 1, 0); List<Integer> y = Arrays.asList(0, 0, 4, 7, 8, 0, 9, 1, 5, 7, 8, 6, 4, 7); System.out.println(hasConsecutivePositive(x, 6)); // false System.out.println(hasConsecutivePositive(y, 6)); // true（子序列 [9,1,5,7,8,6] 全 > 0）
⚠️ 注意事项：
-
reduce在此场景下不提供短路能力（即即使第 6 个满足元素出现后，Stream 仍会继续处理剩余元素）。若数据量极大且性能敏感，建议改用传统for循环配合break实现真正短路； - 初始值
0和累加逻辑必须严格匹配语义：0表示“尚未开始连续计数”，而非“默认满足”； - 该方法天然支持参数化（如
consecutiveDays），便于复用到不同业务阈值（如连续 3 天、10 天等）。
总结：Stream.reduce() 是处理带状态连续性判断的简洁方案，虽牺牲了部分短路性，但以声明式风格显著提升了逻辑可读性与维护性。对于中小规模数据或强调代码清晰度的场景，它是比手动循环更优的 Java 8 风格解法。
