Gatherer是Java 22引入的专用于有状态窗口计算的标准化Stream中间操作，通过initializer、integrator、combiner、finisher四阶段精确控制状态生命周期，解决map/flatMap无法安全实现滑动/固定窗口的线程安全、末尾处理与并行兼容等核心缺陷。
Java 22 引入的 Gatherer 是目前唯一能安全、标准地实现有状态窗口计算（如滑动、固定、会话窗口）的 Stream 中间操作机制。它不是“增强版 map”或“带状态的 flatMap”，而是专为「按序观察 + 状态维持 + 按需产出」设计的底层接口。
为什么不能用 map 或 flatMap 做窗口计算
常见错误是试图在 map 中用静态变量或外部 List 缓存元素，这会导致：
• 多线程下状态污染（并行流必崩）
• 流被多次消费时结果不一致（Stream 不可重用）
• 无法处理流末尾的不完整窗口（比如 windowFixed(3) 遇到 7 个元素，第 7 个必须触发输出 [item7]）
• 无法与 gather 后续操作融合优化（JVM 无法做 pipeline 融合）
Gatherer.of() 四个参数的实际含义和取舍逻辑
每个参数对应窗口行为的一个确定阶段，缺一不可，但部分可设为默认实现：
-
initializer()：返回初始状态对象，比如() -> new ArrayList<string>()</string>。无状态转换（如纯映射）可返回() -> null，但窗口类操作必须返回可变容器 -
integrator()：核心逻辑。签名是(state, element, downstream) -> void。注意：必须显式调用downstream.accept(result)才会向下游发射元素；不调用 = 丢弃；调用多次 = 多对多输出 -
combiner()：仅并行流需要。例如两个线程各自维护一个ArrayList，需合并成一个。若只跑串行流，可设为(a, b) -> { throw new UnsupportedOperationException(); } -
finisher()：流结束时调用，用于清空缓冲区。比如窗口未满，就downstream.accept(state)。不可省略，否则末尾数据丢失
写一个带边界检查的 windowSliding(2, 1)（大小 2、步长 1）
这是最易出错的场景：既要维护长度为 2 的滑动窗口，又要保证每次移动只吐出新窗口（不能重复、不能跳过）。关键点在于状态必须是可变且可复用的列表，且 integrator 中要控制何时输出：
Gatherer<integer list>, List<integer>> slidingWindow =
Gatherer.of(
() -> new ArrayList(2), // 初始容量 2，避免扩容
(window, item, downstream) -> {
window.add(item);
if (window.size() == 2) {
downstream.accept(new ArrayList(window)); // 必须 new，否则后续修改影响已发出引用
window.remove(0); // 滑动：移除最老元素
}
},
(a, b) -> { throw new UnsupportedOperationException(); },
(window, downstream) -> {
if (!window.isEmpty() && window.size() > 1) {
downstream.accept(new ArrayList(window));
}
}
);</integer></integer>
使用：Stream.of(1,2,3,4).gather(slidingWindow).forEach(System.out::println) 输出 [1, 2], [2, 3], [3, 4]。
内置 Gatherers.windowFixed(n) 为什么比手写更可靠
直接用 Gatherers.windowFixed(3) 而非自己实现，不只是省事：
- 已通过
combiner正确支持并行流：各分段窗口独立缓存，最后按顺序合并，不破坏窗口边界 -
finisher严格处理流末尾：哪怕只剩 1 个元素，也包装成List发出 - 内部使用了轻量级数组缓冲，避免
ArrayList的扩容开销和 GC 压力 - 与后续
collect(toList())可自动融合——JVM 会跳过中间List<list>></list>构造，直接累积进最终容器
真正复杂的是状态生命周期管理，不是窗口逻辑本身。用内置实现，等于把状态初始化、并发合并、终结清理这些容易出错的环节交给 JDK 保障。
