parallelStream导致LinkedList遍历时空指针的问题

亦凉 2023-02-16 06:56 14阅读 0赞

最近在开发中遇到一个问题，在遍历一个LinkedList时偶然性的会发生空指针。前面儿是通过parrallelStream往这个LinkedList里面添加元素，导致的这个问题，parrallelStream是并行流，而LinkedList和ArrayList都不是线程安全的，就可能会导致这个问题。

例如下面一段代码，运行几次，偶然就会出现空指针

public class TestLinkedList {
    
        public static void main(String[] args) {
    
            List<Integer> list = new LinkedList<>();
            List<Integer> list1 = new ArrayList<>();
            for(int j=0; j < 1000; j++){
                list1.add(j);
            }
            list1.parallelStream().forEach(t -> list.add(t));
            for (Integer integer : list) {
                System.out.println(integer);
            }
            System.out.println(list.size());
        }
    }

运行结果偶尔会出现空指针

Exception in thread "main" java.lang.NullPointerException
    	at java.util.LinkedList$ListItr.next(LinkedList.java:893)
    	at com.zhangmen.info.job.aop.TestLinkedList.main(TestLinkedList.java:23)

解决办法:将LinkedList和ArrayList变成线程安全的集合就没问题了。

public class TestLinkedList {
    
        public static void main(String[] args) {
    
            List<Integer> list = Collections.synchronizedList(new LinkedList<>());
            List<Integer> list1 = new ArrayList<>();
            for(int j=0; j < 1000; j++){
                list1.add(j);
            }
            list1.parallelStream().forEach(t -> list.add(t));
            for (Integer integer : list) {
                System.out.println(integer);
            }
            System.out.println(list.size());
        }
    }

这样可以解决并发时不安全的问题。