Java Stream过滤含子列表对象：优雅高效实现方案咨询

现有代码的优缺点分析 #

原peek版本问题 #

• 误用peek：peek设计用于调试流元素，而非修改对象状态，可读性和规范性差。
• 并行流滥用：无差别使用并行流，小数据量下线程调度开销会抵消并行收益。

优化后的map版本优势 #

• 代码拆分更清晰：将过滤逻辑提取为独立方法，提升可读性和可维护性。
• 符合流API设计意图：用map处理对象转换/修改，比peek更规范。

进一步优化建议 #

1. 合理控制并行流的使用 #

并行流存在线程池调度开销，仅当数据量达到一定阈值（比如父列表>100条、子列表>50条）时才启用，否则用串行流更高效：

@CachePut(value="sdipp-cache")
public List<Attivita> ottieniListaAttivita(String prefixCall, Long idIstanza) throws DefaultException {
    List<Attivita> attivitaList = servizioGenerico.ottieniCall(prefixCall).getListaAttivita();
    Stream<Attivita> stream = attivitaList.size() > 100 ? attivitaList.parallelStream() : attivitaList.stream();
    return stream.map(att -> filtroLavorazioniAttivitaSuIstanza(att, idIstanza))
                 .collect(Collectors.toList());
}

private Attivita filtroLavorazioniAttivitaSuIstanza(Attivita attivita, Long idIstanza) {
    List<Lavorazione> lavorazioni = attivita.getListaLavorazioni();
    Stream<Lavorazione> lavStream = lavorazioni.size() > 50 ? lavorazioni.parallelStream() : lavorazioni.stream();
    
    List<Lavorazione> filteredLav = lavStream
            .filter(lav -> idIstanza.equals(lav.getIstanza().getId()))
            .collect(Collectors.toCollection(ArrayList::new));
    
    attivita.setListaLavorazioni(filteredLav);
    return attivita;
}

2. 避免对象修改副作用（关键优化） #

当前代码直接修改原Attivita对象，结合@CachePut会导致缓存中的对象与原对象引用一致，后续对原对象的修改会污染缓存。建议创建新对象，避免副作用：

private Attivita filtroLavorazioniAttivitaSuIstanza(Attivita attivita, Long idIstanza) {
    // 复制原对象属性到新实例（可通过构造器、BeanUtils等方式简化）
    Attivita filteredAttivita = new Attivita();
    filteredAttivita.setId(attivita.getId());
    filteredAttivita.setCodice(attivita.getCodice());
    // ... 复制其他必要属性
    
    List<Lavorazione> lavorazioni = attivita.getListaLavorazioni();
    Stream<Lavorazione> lavStream = lavorazioni.size() > 50 ? lavorazioni.parallelStream() : lavorazioni.stream();
    
    List<Lavorazione> filteredLav = lavStream
            .filter(lav -> idIstanza.equals(lav.getIstanza().getId()))
            .collect(Collectors.toCollection(ArrayList::new));
    
    filteredAttivita.setListaLavorazioni(filteredLav);
    return filteredAttivita;
}

3. 细节优化 #

• 明确收集器实现：用Collectors.toCollection(ArrayList::new)替代Collectors.toList()，避免不同Java版本中toList()返回列表类型不一致的问题。
• 减少重复方法调用：如果lavorazione.getIstanza()调用开销大，可提前提取实例缓存，但当前场景中getId()是轻量操作，无需额外优化。

注意事项 #

• 若Attivita是JPA实体，直接修改原对象可能触发持久化上下文的自动更新，引发意外数据库操作，使用新实例更安全。
• 并行流默认使用公共ForkJoinPool，高并发场景下可自定义线程池避免资源竞争：

  ForkJoinPool customPool = new ForkJoinPool(4);
  List<Attivita> result = customPool.submit(() -> 
      attivitaList.parallelStream()
                  .map(att -> filtroLavorazioniAttivitaSuIstanza(att, idIstanza))
                  .collect(Collectors.toList())
  ).join();
  

内容的提问来源于stack exchange，提问作者Danilo Giovannico