
java并行流中直接修改共享集合(如arraylist)会导致线程不安全;虽可用synchronized包装lambda,但违背流式编程原则、损害性能,正确做法是使用线程安全的collector进行归约。
在Java中,IntStream.range(0, 100).parallel().forEach(s -> data.add(s)) 这类写法看似简洁,实则存在严重问题:ArrayList 本身不是线程安全的,而 parallel() 会启用多个线程并发执行 forEach 中的 lambda。这将导致:
- 数据丢失或重复:add() 操作包含“读取size→插入元素→更新size”多个步骤,多线程下极易发生竞态条件;
- 不可预测结果:运行多次可能输出 97、99、甚至抛出 ConcurrentModificationException(取决于JVM实现与调度);
- 同步lambda治标不治本:即使强行用 synchronized(data) { data.add(s); } 包裹,也会因全局锁导致严重线程争用,使并行流退化为串行,完全丧失并行优势。
✅ 正确解法:摒弃外部可变状态,拥抱不可变归约(reduction)
Java Stream API 设计哲学强调「无副作用」(side-effect-free)。针对本例——生成 0 到 99 的整数列表——应使用 collect() 配合标准 Collector,由框架内部保证线程安全与高效合并:
import java.util.List;
import java.util.stream.Collectors;
import java.util.stream.IntStream;
public class Q03 {
public static void main(String[] args) {
List data = IntStream.range(0, 100)
.parallel() // ✅ 并行执行无压力
.boxed() // int → Integer(为后续collect准备)
.collect(Collectors.toList()); // ✅ 线程安全、自动分段合并
System.out.println(data.size()); // 输出稳定:100
}
} ? 关键原理说明:
- Collectors.toList() 返回的是一个并发感知的 Collector,在并行流中会自动采用分段收集(fork-join)策略:各线程独立构建子列表,最后高效合并,全程无需显式锁;
- boxed() 是必需的,因为 IntStream 是原始类型流,而 Collectors.toList() 要求引用类型流(Stream
); - 若需其他集合类型,可选用 Collectors.toSet()、Collectors.toCollection(ArrayList::new) 等,均具备同等线程安全性。
⚠️ 补充提醒:
- forEach() 和 peek() 是少数允许副作用的操作,但仅推荐用于日志调试等非业务场景;生产代码中应优先使用 map/filter/reduce/collect 等无状态操作;
- 若必须操作外部状态(极少数例外),应使用线程安全容器(如 CopyOnWriteArrayList 或 ConcurrentLinkedQueue),但仍不如 collect() 语义清晰、性能优越。
总结:与其费力同步一个危险的 lambda,不如重写为声明式归约——这是 Java 流式编程的惯用范式,兼顾正确性、性能与可维护性。










