Java 中高效过滤嵌套列表：使用 Stream 重构父子结构的优雅实践

如何优雅、安全地过滤嵌套列表？在 Ja va 开发中，处理“父对象列表 + 每个父对象持有一个子对象列表”这类结构，并按条件（比如 idIstanza）过滤子项，是常见但稍不留神就会踩坑的场景。

先看看一种常见的写法——用 peek() 或 map() 搭配 parallelStream()，直接在原对象上修改内部列表：

.map(attivita -> {    attivita.setListaLa vorazioni(        attivita.getListaLa vorazioni().stream()            .filter(l -> l.getIstanza().getId().equals(idIstanza))            .collect(Collectors.toList())    );    return attivita;})

这段代码看起来简洁，但其实藏着好几个隐患：

• 线程不安全：一旦启用 parallelStream()，多个线程会并发调用 setListaLa vorazioni()。如果 Attivita 是共享的可变对象，竞态条件几乎是必然的。
• 违背函数式原则：peek() 本来只适合调试（看看中间结果），不该承担业务逻辑；map() 虽然合法，但在原对象上做突变（mutating）操作，破坏了不可变性。
• 性能误导：对于中小规模集合（比如子列表平均不到 100 项），parallelStream() 的线程调度和拆分开销比顺序流还高，得不偿失。

✅ 推荐方案：面向对象封装 + 不可变语义

一个更靠谱的做法是：把过滤逻辑内聚到 Attivita 类里，遵循“信息专家”原则——逻辑就应该待在数据所在的地方，避免外部直接侵入内部结构。

// Attivita.ja va —— 封装子列表过滤能力，返回新实例（推荐不可变设计）
public Attivita filterLa vorazioniById(Long idIstanza) {
    List filtered = this.listaLa vorazioni.stream()
        .filter(l -> Objects.equals(l.getIstanza().getId(), idIstanza)) // 用 Objects.equals 防 NPE
        .toList(); // Ja va 16+，或 collect(Collectors.toList())
    
    // 方式1：若 Attivita 支持构建器（推荐）
    return new Attivita.Builder(this)
        .withListaLa vorazioni(filtered)
        .build();
    // 方式2：若为 record 或不可变类（Ja va 14+）
    // return new Attivita(this.id, this.nome, filtered, ...);
}

服务层的代码就变成了这样——清晰、安全、可读性拉满：

@CachePut(value = "sdipp-cache")
public List ottieniListaAttivita(String prefixCall, Long idIstanza) throws DefaultException {
    return servizioGenerico.ottieniCall(prefixCall)
        .getListaAttivita()
        .stream() // ✅ 默认顺序流已足够，除非列表 > 10k 且子列表极长
        .map(attivita -> attivita.filterLa vorazioniById(idIstanza))
        .collect(Collectors.toList());
}

⚠️ 关键注意事项

• 别盲目用并行流：parallelStream() 只有在数据量很大（比如父列表 ≥ 10,000）、子列表计算密集（涉及复杂 I/O 或 CPU 运算）时才划算。日常业务场景，顺序流就足够了。
• 防御性编程：la vorazione.getIstanza() 或 .getId() 可能为 null，务必用 Objects.equals() 替代直接 == 或 .equals() 调用，防止空指针捣乱。
• 不可变优于可变：如果暂时无法把 Attivita 改造成不可变类，至少确保 filterLa vorazioniById() 返回新对象，而不是修改原对象——这是并发安全的基石。
• 缓存友好性：当前 @CachePut 作用在整个 List 上，如果后续需要更细粒度的缓存（比如按 idIstanza 缓存子列表），可以把 filterLa vorazioniById() 提升为独立的缓存方法。

把领域逻辑下沉到实体类、拥抱不可变性、再用流式组合起来——这样做出来的代码不仅更健壮、更容易测试，也让并行处理从“风险操作”变成了“自然选择”。