避免peek()与forEach()副作用：Java Stream修改集合属性最佳实践

符合规范的实现方案 #

方案1：优先选择无多余副作用的Stream写法 #

核心原则是不要在流操作内部修改外部可变状态，先通过流完成映射/过滤操作、收集出待处理的对象集合，再针对集合本身做属性修改，最后合并保存：

HashMap<Integer, Double> quantities;
ArrayList<OrderDetail> orderDetails;

public void updateStock() {
    // 处理出库仓：扣减库存
    List<ProductWarehouse> sources = orderDetails.stream()
            .map(OrderDetail::getSource)
            .toList();
    sources.forEach(src -> src.setAvailableStock(
        src.getAvailableStock() - quantities.get(src.getProductId())
    ));

    // 处理入库仓：增加库存
    List<ProductWarehouse> destinies = orderDetails.stream()
            .map(OrderDetail::getDestiny)
            .toList();
    destinies.forEach(dst -> dst.setAvailableStock(
        dst.getAvailableStock() + quantities.get(dst.getProductId())
    ));

    // 合并后批量保存
    List<ProductWarehouse> updated = Stream.concat(sources.stream(), destinies.stream())
            .toList();
    productWarehouseRepository.save(updated);
}

方案2：直接用增强for循环（更适配当前场景） #

你当前的场景不需要复杂的流操作，直接遍历orderDetails一次就能同时处理source和destiny，代码更简洁、遍历效率更高：

HashMap<Integer, Double> quantities;
ArrayList<OrderDetail> orderDetails;

public void updateStock() {
    List<ProductWarehouse> updated = new ArrayList<>();
    for (OrderDetail detail : orderDetails) {
        ProductWarehouse src = detail.getSource();
        src.setAvailableStock(src.getAvailableStock() - quantities.get(src.getProductId()));
        updated.add(src);

        ProductWarehouse dst = detail.getDestiny();
        dst.setAvailableStock(dst.getAvailableStock() + quantities.get(dst.getProductId()));
        updated.add(dst);
    }
    productWarehouseRepository.save(updated);
}

常见疑问澄清 #

1. 为什么不推荐你最初的Stream写法？
   你最初的写法在forEach中修改外部的updated集合，属于官方明确不推荐的「不必要副作用」：如果后续你把流改成并行流，ArrayList非线程安全的特性会直接导致数据丢失、数组越界等不可预期的错误，风险是真实存在的。
2. 能不能用peek实现？
   绝对不推荐。官方明确说明peek是调试工具，生产环境使用有严重隐患：如果流是短路操作（比如搭配findFirst()、limit()），或者后续没有终端操作触发流执行，peek中的逻辑可能完全不会运行，且这种问题很难排查。
3. 什么时候适合用Stream修改元素属性，什么时候用普通循环？

• 如果你的处理逻辑包含过滤、去重、分组、聚合等Stream原生支持的操作，用Stream更简洁：先把待修改的元素通过map/filter等操作筛选出来，收集为集合后再调用Iterable.forEach修改属性即可。
• 如果只是简单遍历、没有复杂的集合处理逻辑，直接用增强for循环可读性更高，没必要硬套Stream API。

内容的提问来源于stack exchange，提问作者Jetto Martínez