parallelStream().forEach操作ArrayList致输出不一致问题求助

问题出在哪？ #

你遇到的核心问题是**ArrayList不是线程安全的集合**。在并行流中，多个线程会同时调用itemIdList.add()和linkedItemIds.add()方法，而ArrayList的add()操作没有任何同步机制，会触发竞态条件：

• 当多个线程同时更新集合内部的size计数时，可能出现计数丢失，导致最终集合大小小于预期；
• 集合扩容时的数组复制操作也可能被多个线程打断，造成元素覆盖或丢失。
  这就是同一批输入每次执行后集合大小不一致的原因。

另外需要注意：代码中共享的error集合如果是非线程安全实现（比如普通ArrayList），同样会存在并发问题，导致校验逻辑结果混乱。

修复方案 #

方案1：使用线程安全的集合 #

将ArrayList替换为线程安全的实现，比如CopyOnWriteArrayList或Collections.synchronizedList()：

List<String> itemIdList = new CopyOnWriteArrayList<>();
List<String> linkedItemIds = new CopyOnWriteArrayList<>();
// 后续并行流逻辑不变（注意error集合需改为线程安全，或每个线程独立创建）

不过CopyOnWriteArrayList每次写操作都会复制整个数组，元素数量庞大时性能会受影响，更推荐下面的方案。

方案2：使用并行流的collect()方法（推荐） #

并行流的collect()方法专为并发聚合设计，内部会自动处理线程安全的结果收集，无需手动维护线程安全集合：

// 收集itemIdList，直接通过map+collect完成
List<String> itemIdList = items.parallelStream()
    .map(item -> item.getId())
    .collect(Collectors.toList());

// 收集linkedItemIds，先过滤校验通过的元素，再收集
List<String> linkedItemIds = items.parallelStream()
    .filter(item -> {
        // 每个线程独立创建error集合，避免共享导致的并发问题
        List<String> error = new ArrayList<>();
        validateLinkedItemStatus(order, error);
        return CollectionUtils.isEmpty(error);
    })
    .map(item -> item.getLinkedId())
    .collect(Collectors.toList());

这种方式不仅解决了线程安全问题，还更符合Java流的设计理念，代码可读性和性能都更优。

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