并行流（Parallel Stream）向数组添加元素引发空指针异常问题

老哥，我太懂这种并行流踩坑的痛苦了！你遇到的这个NullPointerException十有八九是线程安全问题搞的鬼，而且因为并行流的线程调度随机性，只会在运行时触发，调试起来确实挠头。结合你的描述，我帮你拆解下问题根源和解决办法：

问题根源分析 #

你提到用.parallel()后速度翻倍但出现空指针，最大的可能性是：

• 你在并行流中使用了非线程安全的集合（比如普通ArrayList）来收集处理后的对象。多个线程同时执行add操作时，会触发集合内部的竞态条件（比如数组扩容时的元素覆盖、索引错乱），直接导致集合中出现null元素。
• 另一种可能是你直接修改了原数组中的对象，而原对象本身存在线程不安全的状态（比如未同步的属性修改），并行修改后对象处于半初始化状态，最终被存入新数组时变成null。

针对性解决方案 #

1. 用并行流自带的线程安全收集器（最优方案） #

别手动用同步函数往集合里加元素了！并行流的collect方法搭配Collectors工具类，会自动处理线程间的元素合并，完全线程安全，还能保持并行的性能优势。示例代码如下：

// 假设原数组是oldArray
Object[] newArray = Arrays.stream(oldArray)
    .parallel()
    .map(obj -> {
        // 重点：不要直接修改原对象！创建副本后再修改，避免污染原数组+线程安全问题
        Object newObj = deepCopyOrClone(obj); // 实现对象的复制逻辑
        modifyNewObject(newObj); // 在副本上执行修改操作
        return newObj;
    })
    .collect(Collectors.toList())
    .toArray(new Object[0]);

2. 若必须手动收集，使用线程安全容器 #

如果因为某些原因不能用collect，可以改用线程安全的集合，比如CopyOnWriteArrayList（注意：写操作多的场景下性能一般，优先推荐上面的收集器方案）：

List<Object> threadSafeList = new CopyOnWriteArrayList<>();
Arrays.stream(oldArray)
    .parallel()
    .map(obj -> {
        Object newObj = copyAndModify(obj);
        return newObj;
    })
    .forEach(threadSafeList::add);
Object[] newArray = threadSafeList.toArray(new Object[0]);

3. 排查修改逻辑中的空指针隐患 #

检查你的修改操作modifyObj：是否在并行场景下某些分支会返回null？比如依赖的资源未初始化、对象属性在多线程下被意外置空。可以在map中加入非空校验：

.map(obj -> {
    if (obj == null) {
        // 处理原对象为空的情况，比如返回默认对象或跳过
        return createDefaultObject();
    }
    Object newObj = copyAndModify(obj);
    return newObj;
})

关键提醒 #

并行流的核心是无状态操作：每个线程处理的对象应该是独立的，不要共享可变状态，也不要直接修改原数据。一旦违反这个原则，就会出现各种诡异的线程安全问题，而且很难复现和调试。

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