java分批应优先用sublist或guava lists.partition,避免stream.collect硬凑;需注意视图修改风险、空值校验及并发安全。

Java原生List分批:别直接用Stream.collect()硬凑
Stream API本身不提供“按大小切分List”的终端操作,collect()只能归约到单个结果,强行用Collectors.groupingBy()配合索引计数既难读又易错——尤其在并行流下索引会乱序。真正靠谱的起点是把List转成可索引访问的结构,再按步长截取。
- 用
list.subList(fromIndex, toIndex)最轻量,但要注意它返回的是原List的视图,修改会影响原集合;如需独立副本,得套一层new ArrayList(...) - 避免在循环里反复调用
stream().skip().limit(),每次都会遍历前N项,时间复杂度O(n²),10万元素就明显卡顿 - 如果原始List是
LinkedList,subList()性能尚可;但如果是ArrayList,随机访问快,subList()也快——别被“链表适合分页”这种过时经验带偏
Guava的Lists.partition():简单场景首选,但注意返回值语义
Lists.partition(list, size)确实一行解决分批,但它返回的是List<list>></list>,且每个子List仍是原List的subList视图。这意味着:
- 如果后续要对某个分片做
add()或remove(),会抛UnsupportedOperationException——因为subList默认不支持结构性修改 - 若原始List后续被修改(比如clear()),所有partition出来的子List会同步失效,读取时可能抛
ConcurrentModificationException - size ≤ 0会直接抛
IllegalArgumentException,生产代码里必须提前校验,不能依赖Guava兜底
Stream分批归约:用Collectors.collectingAndThen + 自定义Collector
真要用Stream做分批归约,核心是控制“累积器状态”,而不是靠map/filter拼凑。推荐封装一个复用的Collector,例如:
Collector<t list>>> partitioning(int size) {
return Collector.of(
() -> new ArrayList<list>>(),
(acc, item) -> {
if (acc.isEmpty() || acc.get(acc.size()-1).size() == size) {
acc.add(new ArrayList());
}
acc.get(acc.size()-1).add(item);
},
(a, b) -> { throw new UnsupportedOperationException(); }, // 不合并
collectingAndThen(identity(), x -> x)
);
}
</list></t>
关键点:
- 第三个参数(combiner)必须抛异常或明确注释“不支持并行”,因为分批逻辑天然有顺序依赖
- 别用
Collectors.toMap()模拟分组,key算索引再取模,流式处理中无法保证元素到达顺序,结果不可靠 - 这个Collector返回的是全新List实例,和原List完全解耦,适合需要后续修改分片内容的场景
边界情况和性能提醒:size为0、null、超大分片
实际写业务时,size参数往往来自配置或用户输入,最容易漏掉这些检查:
-
size == 0:Guava直接炸;原生subList(0, 0)虽合法,但循环里容易陷入死循环(步长为0) -
list == null:Guava和自定义Collector都不会自动判空,NPE风险高,建议前置Objects.requireNonNull(list) -
size > list.size():Guava返回单元素List,符合直觉;但自己写循环时若没处理好边界,可能漏掉最后一段 - 分片数上万时,Guava的
partition内存占用略低(共享底层数组);而Stream Collector每段都new ArrayList,GC压力稍大——但差不了几个MB,别过早优化
分批这事,核心从来不是“怎么写出来”,而是想清楚:分完之后要不要改、原List会不会变、并发环境下谁负责同步。这几个问题没答案,代码写得再短也没用。
Java免费学习笔记:立即使用
解锁 Java 大师之旅:从入门到精通的终极指南











