Java Gatherer.Downstream 怎样在结束阶段发送尾部元素
Java Gatherer.Downstream 发送尾部元素的关键,是把“输入结束”交给 finisher 处理,而不是在 integrator 里猜测下一次输入是否存在。每次输入先进入状态;状态凑满一组就立即 push,还没凑满的最后一组留到 finisher,再通过同一个下游发送。这样既不会丢掉尾部数据,也不会把完整分组重复发送。
官方文档:https://docs.oracle.com/en/java/javase/24/docs/api/java.base/java/util/stream/Gatherer.Downstream.html
integrator负责接收输入和发送已经完成的结果。finisher只处理上游结束时残留的状态,空状态不输出。push返回false表示下游不再接受后续元素;默认 combiner 则意味着按顺序执行。
先分清 integrator 与 finisher 的职责
Gatherer 是 Stream 的中间操作,既可以逐个输入地产生输出,也可以在上游结束时做一次最终动作。一个实用的分组场景是:每 3 个数字输出一个完整列表,末尾不足 3 个的数字也要保留。
| 阶段 | 负责什么 | 不要做什么 |
|---|---|---|
| integrator | 接收当前元素,更新状态,满组后 push | 等待一个不存在的“下一个元素” |
| finisher | 检查残留状态并发送尾部组 | 把空状态发送成空分组 |
| Downstream | 接受或拒绝当前输出 | 被长期保存到状态对象中 |
官方 API 对 Downstream.push 的约定是:返回 true 表示还可以继续发送,返回 false 后后续 push 都不会再被接受。因此,尾部发送前可以用 isRejecting() 做一次尽力判断;但它不是替代 push 返回值的绝对保证。

用 ofSequential 保存未完成分组
下面的示例只做顺序分组,因此使用 Gatherer.ofSequential。状态是当前尚未发送的列表;达到批大小后先复制,再发送,再清空原状态。发送副本很重要,否则后续 clear() 会让下游看到被修改的列表。
import java.util.ArrayList; import java.util.List; import java.util.stream.Gatherer; static Gatherer, List > batchesWithTail(int batchSize) { if (batchSize { state.add(element); // 先把当前输入放入未完成分组 if (state.size() { if (!state.isEmpty() && !downstream.isRejecting()) { downstream.push(List.copyOf(state)); // 上游结束,发送最后的不完整分组 } } ); }
例如输入 1, 2, 3, 4, 5 且 batchSize=3 时,结果是 [[1, 2, 3], [4, 5]]。输入为空时,状态从未加入元素,finisher 不会制造一个空列表。

短路、空输入与并行边界
不要无条件忽略 push 的返回值。下游可能由 findFirst 等短路操作构成,完整分组发送时返回 false,上游就不应继续生产。finisher 的返回类型是 void,它只能在发送前检查状态和下游状态;真正的接受结果仍由 push 表达。
这个实现选择 ofSequential,因为“当前尾部状态”有明确的顺序含义。若改用可并行的 Gatherer.of,就必须提供能合并两个分区状态的 combiner,并重新定义跨分区的分组顺序。仅仅把 ofSequential 换成 of,会让尾部结果的边界变得不可靠。
常见问题
finisher 会在每个输入元素后执行吗?
不会。它对应上游结束阶段;每个元素的处理仍由 integrator 完成。
为什么要使用 List.copyOf?
因为发送后要清空可变状态。复制后,下游拿到的是不会被后续 clear() 改写的结果。
finisher 里能继续保存 Downstream 吗?
不能。Downstream 只应在当前回调调用期间使用,状态对象也不应长期持有它。
Java Thread.Builder factory 怎样复用虚拟线程的命名规则
- 上一篇
- Java Thread.Builder factory 怎样复用虚拟线程的命名规则
- 下一篇
- Java SequencedSet reversed 怎样反向遍历不复制集合
-
- 文章 · java教程 | 6分钟前 | 并发 · Java · java arena MemorySegment FFM API
- Java Arena.ofConfined 与 ofShared 如何选择
- 335浏览 收藏
-
- 文章 · java教程 | 7分钟前 | java Event JFR shouldCommit 事件过滤
- Java JFR Event 怎样只记录满足条件的事件
- 412浏览 收藏
-
- 文章 · java教程 | 12分钟前 | 虚拟线程 · 性能边界 · java 并发 threadlocal 资源释放 ScopedValue Virtual Threads
- Java virtual threads 与 ThreadLocal 资源绑定的清理边界
- 339浏览 收藏
-
- 文章 · java教程 | 15分钟前 | java websocket 重连 httpclient 消息顺序
- Java HttpClient WebSocket 怎样处理重连后的消息顺序
- 146浏览 收藏
-
- 文章 · java教程 | 15分钟前 | java LinkedHashSet SequencedCollection reversed SequencedSet
- Java SequencedSet reversed 怎样反向遍历不复制集合
- 248浏览 收藏
-
- 文章 · java教程 | 18分钟前 | 工程实践 · 虚拟线程 · java 虚拟线程 ThreadFactory 线程命名 Thread.Builder
- Java Thread.Builder factory 怎样复用虚拟线程的命名规则
- 233浏览 收藏
-
- 文章 · java教程 | 23分钟前 | java 请求上下文 StructuredTaskScope ScopedValue
- Java ScopedValue 怎样把请求上下文传给子任务
- 315浏览 收藏
-
- 文章 · java教程 | 9小时前 | Java · java 正则表达式 pattern named group
- Java Pattern named group 提取结构化文本的方法
- 333浏览 收藏
-
- 文章 · java教程 | 12小时前 | 字符串 · 工程实践 · Java教程 · java Locale.ROOT String.toLowerCase String.toUpperCase 机器可读字符串
- Java Locale.ROOT 固定机器可读字符串大小写的做法
- 436浏览 收藏
-
- 文章 · java教程 | 12小时前 | Java · 文件下载 · java httpclient Content-Disposition BodyHandlers ofFileDownload filename
- Java BodyHandlers.ofFileDownload 怎样按响应头命名文件
- 438浏览 收藏
-
- 前端进阶之JavaScript设计模式
- 设计模式是开发人员在软件开发过程中面临一般问题时的解决方案,代表了最佳的实践。本课程的主打内容包括JS常见设计模式以及具体应用场景,打造一站式知识长龙服务,适合有JS基础的同学学习。
- 543次学习
-
- GO语言核心编程课程
- 本课程采用真实案例,全面具体可落地,从理论到实践,一步一步将GO核心编程技术、编程思想、底层实现融会贯通,使学习者贴近时代脉搏,做IT互联网时代的弄潮儿。
- 516次学习
-
- 简单聊聊mysql8与网络通信
- 如有问题加微信:Le-studyg;在课程中,我们将首先介绍MySQL8的新特性,包括性能优化、安全增强、新数据类型等,帮助学生快速熟悉MySQL8的最新功能。接着,我们将深入解析MySQL的网络通信机制,包括协议、连接管理、数据传输等,让
- 500次学习
-
- JavaScript正则表达式基础与实战
- 在任何一门编程语言中,正则表达式,都是一项重要的知识,它提供了高效的字符串匹配与捕获机制,可以极大的简化程序设计。
- 487次学习
-
- 从零制作响应式网站—Grid布局
- 本系列教程将展示从零制作一个假想的网络科技公司官网,分为导航,轮播,关于我们,成功案例,服务流程,团队介绍,数据部分,公司动态,底部信息等内容区块。网站整体采用CSSGrid布局,支持响应式,有流畅过渡和展现动画。
- 485次学习
-
- PubMedQA
- 深入了解PubMedQA生物医学问答数据集,涵盖其核心功能、使用方法及在临床决策、药物研发等场景的应用,助力提升NLP模型性能。
- 1018次使用
-
- H2O EvalGPT
- H2O EvalGPT是H2O.ai推出的开源LLM评估平台,提供详细的大模型性能排行榜、行业特定基准测试及A/B测试功能,助您快速选择最适合项目的高性能大语言模型。
- 1020次使用
-
- LMArena
- LMArena是加州大学伯克利分校推出的AI模型匿名评测平台。通过盲测投票机制,用户可对比不同大模型回答并生成实时排行榜,助力开发者优化模型及用户选择最佳AI工具。
- 1155次使用
-
- HELM
- 深入了解斯坦福推出的HELM(Holistic Evaluation of Language Models)大模型评测体系。本文解析其核心功能、安装配置步骤及应用场景,涵盖准确性、公平性、鲁棒性等多维度指标,助力开发者全面优化语言模型性能。
- 1121次使用
-
- MMBench
- MMBench是由上海人工智能实验室等机构联合推出的多模态基准测试平台,提供细粒度能力评估、大规模数据集及VLMEvalKit工具。本文详细介绍其核心功能、安装使用方法及应用场景,助力开发者全面评估多模态模型性能。
- 962次使用
-
- golang HTTP 服务器 处理 日志/Stream流的操作
- 2023-01-07 289浏览
-
- Redis Stream 消息队列实战:消费组、ACK 和失败重投怎么配
- 2026-06-13 187浏览
-
- Redis XAUTOCLAIM 怎么接管积压消息:游标、最小空闲时间与重试边界
- 2026-08-11 148浏览
-
- Redis XACK/PEL 到底怎么收口:消费组 ACK、pending 与重试边界
- 2026-08-24 339浏览
-
- Redis XTRIM MINID 怎么清理历史消息:近似裁剪、精确裁剪与消费组验收
- 2026-08-25 241浏览

