本文介绍如何优雅、安全地对包含子列表的对象集合进行流式过滤，重点解决并行流中可变对象修改的风险，推荐基于不可变设计与方法封装的高性能实现方案。
本文介绍如何优雅、安全地对包含子列表的对象集合进行流式过滤，重点解决并行流中可变对象修改的风险，推荐基于不可变设计与方法封装的高性能实现方案。
在 Java 开发中，处理“父对象列表 + 每个父对象持有子对象列表”的嵌套结构并按条件（如 idIstanza）过滤子项，是常见但易出错的场景。原始代码使用 peek() 或 map() 配合 parallelStream() 直接修改对象状态：
.map(attivita -> {
attivita.setListaLavorazioni(
attivita.getListaLavorazioni().stream()
.filter(l -> l.getIstanza().getId().equals(idIstanza))
.collect(Collectors.toList())
);
return attivita;
})这种写法存在三大隐患：
✅ 线程不安全：parallelStream() 下多个线程并发调用 setListaLavorazioni()，若 Attivita 为共享可变对象，将引发竞态条件；
✅ 违背函数式原则：peek() 本用于副作用调试，不应承担业务逻辑；map() 虽合理，但仍在原对象上做突变（mutating），破坏不可变性；
✅ 性能误导：对中小规模集合（如子列表平均 < 100 项），parallelStream() 的线程调度与拆分开销反而低于顺序流，得不偿失。
✅ 推荐方案：面向对象封装 + 不可变语义
将过滤逻辑内聚到 Attivita 类中，遵循“信息专家”原则（Logic belongs where the data lives），消除外部对内部结构的侵入式操作：
// Attivita.java —— 封装子列表过滤能力，返回新实例（推荐不可变设计）
public Attivita filterLavorazioniById(Long idIstanza) {
List<Lavorazione> filtered = this.listaLavorazioni.stream()
.filter(l -> Objects.equals(l.getIstanza().getId(), idIstanza)) // 使用 Objects.equals 防 NPE
.toList(); // Java 16+，或 collect(Collectors.toList())
// 方式1：若 Attivita 支持构建器（推荐）
return new Attivita.Builder(this)
.withListaLavorazioni(filtered)
.build();
// 方式2：若为 record 或不可变类（Java 14+）
// return new Attivita(this.id, this.nome, filtered, ...);
}对应服务层代码即可简化为清晰、安全、可读的单行：
@CachePut(value = "sdipp-cache")
public List<Attivita> ottieniListaAttivita(String prefixCall, Long idIstanza) throws DefaultException {
return servizioGenerico.ottieniCall(prefixCall)
.getListaAttivita()
.stream() // ✅ 默认顺序流已足够，除非列表 > 10k 且子列表极长
.map(attivita -> attivita.filterLavorazioniById(idIstanza))
.collect(Collectors.toList());
}⚠️ 关键注意事项
- 避免盲目并行：parallelStream() 仅在数据量大（如父列表 ≥ 10,000）、子列表计算密集（如含复杂 I/O 或 CPU 运算）时收益明显；日常业务中优先用顺序流。
- 防御性编程：lavorazione.getIstanza() 或 .getId() 可能为 null，务必用 Objects.equals() 替代 == 或直接 .equals() 调用。
- 不可变优于可变：若无法改造 Attivita 为不可变类，请至少确保 filterLavorazioniById() 返回新对象而非修改原对象——这是并发安全的基石。
- 缓存友好性：当前 @CachePut 生效于整个 List<Attivita>，若后续需细粒度缓存（如按 idIstanza 缓存子列表），可进一步将 filterLavorazioniById() 提升为独立缓存方法。
通过将领域逻辑下沉至实体、拥抱不可变性与流式组合，你不仅能写出更健壮、可测试的代码，也让并行处理从“风险操作”变为“自然选择”。
立即学习“Java免费学习笔记（深入）”；
