java8新特性-並行Stream線程安全問題

public class App {
    public static void main(String[] args) {
        List<Integer> list = new ArrayList<>();
        for (int i = 0; i < 1000; i++) {
            list.add(i);
        }
        System.out.println(list.size());

        List<Integer> list1 = new ArrayList<>();
        list.stream().forEach(x -> list1.add(x));
        System.out.println(list1.size());

//        List<Integer> list2 = new ArrayList<>();
//        list.parallelStream().forEach(x -> list2.add(x));
//        System.out.println(list2.size());

        List<Integer> list3 = list.parallelStream().collect(Collectors.toList());
        System.out.println(list3.size());
    }
}　　

並行Stream因為考慮效率問題，所以沒有在意線程安全

我們可以使用線程安全的數據流處理使數據同步