Java并行流不保证线程安全，需避免共享可变状态，优先用reduce/collect归约，写入集合时仅用collect、线程安全容器或细粒度同步，并结合JVM参数与压力测试验证。
Java 并行流（parallelStream()）本身不保证线程安全，它只是把任务分发到多个线程执行。线程安全问题不会在编译时报错，而是在运行时随机出现——比如结果不准、集合报 ConcurrentModificationException、下标越界、数据丢失，甚至偶发性超时或 OOM。排查和解决的关键不是“加锁就行”，而是识别共享状态、理解并行机制、选对收集方式。
一、先确认是不是真用了并行流且存在共享写入
很多问题其实源于误判：你以为自己在用并行流，实际可能没生效；或者你以为操作是无副作用的，其实悄悄改了外部变量。
- 检查是否真的调用了
.parallelStream()或.parallel()，而不是.stream() - 搜索代码中所有
forEach、peek、collect前是否有共享对象被修改，例如：
– 修改外部数组（sum[0] += n）
– 向非线程安全集合 add（list.add(x)）
– 调用非原子 setter（obj.setCount(obj.getCount() + 1)） - 注意
forEach是无序且不保证执行顺序的，不能依赖调用次序做状态流转
二、避免共享可变状态：优先用无状态归约代替手动累加
并行流最安全的写法，是彻底不碰外部变量，让框架负责拆分与合并。
- ❌ 错误示范（竞态条件高发）：
int[] total = {0}; numbers.parallelStream().forEach(n -> total[0] += n); - ✅ 推荐写法（自动线程安全）：
int sum = numbers.parallelStream().reduce(0, Integer::sum);
或Optional<integer> max = numbers.parallelStream().max(Integer::compareTo);</integer> - 如果必须累积复杂对象，用
collect配合线程安全的容器或自定义收集器：List<String> result = stream.parallelStream()<br> .filter(...)<br> .map(...)<br> .collect(Collectors.toList());
三、需要写入共享集合时，只用这三种可靠方式
向 ArrayList、HashSet 等非线程安全集合直接 add 是高危操作，极易丢数据或抛异常。正确做法只有以下三类：
立即学习“Java免费学习笔记（深入）”；
-
方案1：用 collect 收集（首选）
框架内部会为每个线程分配独立子容器，最后合并，无需额外同步：List<Integer> safe = IntStream.range(0, 1000).parallel()<br> .boxed().collect(Collectors.toList());
-
方案2：用线程安全容器（次选）
如CopyOnWriteArrayList（适合读多写少）、ConcurrentLinkedQueue（无界、高性能）：List<Integer> list = new CopyOnWriteArrayList<>();<br>IntStream.range(0, 1000).parallel().forEach(list::add);
-
方案3：显式同步（慎用）
仅当无法重构逻辑时采用，注意锁粒度要小，避免成为性能瓶颈：synchronized(list) { list.add(x); }或使用AtomicInteger等原子类替代普通计数器
四、排查工具与验证手段
不能只靠“看代码”，要结合运行时行为验证：
- 开启 JVM 参数观察 ForkJoinPool 使用情况：
-Djava.util.concurrent.ForkJoinPool.common.parallelism=4（可调并行度）
配合 JMC 或 VisualVM 查看 commonPool 的活跃线程数与队列堆积 - 用 JUnit 写压力测试，多次运行并断言结果一致性：
比如对同一数据集反复跑 100 次parallelStream().reduce()，确保每次 sum 都相等 - 日志中重点搜：
–ConcurrentModificationException
–ArrayIndexOutOfBoundsException（常见于 ArrayList 扩容竞争）
– “Timeout waiting for connection”（暗示 commonPool 被阻塞型 IO 占满）
