Java/JDK 19：如何同步Lambda语句以实现线程安全？

你的代码里用了非线程安全的ArrayList，并行流的forEach会在多个线程中同时执行add操作，多个线程同时修改ArrayList的内部结构（比如元素计数、数组扩容）会引发数据竞争，导致最终集合大小可能小于100。

要通过synchronized实现线程安全，只需要把add操作包裹在synchronized同步块里，保证同一时间只有一个线程能执行修改集合的操作。

方法一：同步集合对象本身 #

package sybex.ch00.exercies;

import java.util.ArrayList;
import java.util.List;
import java.util.stream.IntStream;

public class Q03 {

    public static void main(String[] args) {
        List<Integer> data = new ArrayList<>();
        IntStream.range(0, 100).parallel().forEach(s -> {
            // 同步ArrayList对象，确保同一时间只有一个线程执行add操作
            synchronized (data) {
                data.add(s);
            }
        });
        System.out.println(data.size()); // 稳定输出100
    }
}

方法二：使用独立的锁对象 #

如果不想直接锁集合对象（比如集合可能被其他地方同时操作），可以创建一个专门的锁对象：

package sybex.ch00.exercies;

import java.util.ArrayList;
import java.util.List;
import java.util.stream.IntStream;

public class Q03 {

    public static void main(String[] args) {
        List<Integer> data = new ArrayList<>();
        Object lock = new Object(); // 专门用于同步的锁对象
        IntStream.range(0, 100).parallel().forEach(s -> {
            synchronized (lock) {
                data.add(s);
            }
        });
        System.out.println(data.size());
    }
}

补充说明 #

除了synchronized，还有更符合流设计的线程安全写法——用collect方法替代forEach，并行流的collect操作本身就是线程安全的，不需要手动同步：

package sybex.ch00.exercies;

import java.util.List;
import java.util.stream.Collectors;
import java.util.stream.IntStream;

public class Q03 {

    public static void main(String[] args) {
        // collect会为每个线程创建临时容器，最后合并结果，天然线程安全
        List<Integer> data = IntStream.range(0, 100)
                                      .parallel()
                                      .boxed()
                                      .collect(Collectors.toList());
        System.out.println(data.size()); // 稳定输出100
    }
}

内容的提问来源于stack exchange，提问作者Đỗ Như Vỹ