List集合多线程并发条件下不安全怎么办？新来的同事直接被我给问懵了

Posted 2021-06-05 守夜人爱吃兔子

前言

前段时间公司来了一位新员工，说是新员工其实在来我们公司之前，就已经在外包码了一年半的代码了，有次和他闲聊聊到了List,我随口问他之前在外包时，List集合多线程并发不安全是怎么解决的，没想到他直接一脸懵圈看着我，说这玩意还带不安全的？我也是一脸无语，问他上了一年半的班是在干嘛，这都不清楚。他说之前在外包差不多每天就是混日子，觉得不能这样下去了才会想着离职换个好点的工作的。我只能说幸好他“醒悟”的早

在日常开发过程中，List是我们常用的集合，比如查询数据库内容返回值比会用一个集合来装，但是在多线程并发的条件下，会出现安全问题吗？下面我们就来测试一下，如果出现安全问题，该如何解决.

 

一、List集合使用模拟并发测试

1 单线程环境下

public static void main(String[] args) {
    // List集合
    List<String> list = new ArrayList<>();
    // 循环插入
    for (int i = 0; i < 10; i++) {
        list.add(UUID.randomUUID().toString().substring(0,5));
        System.out.println(list);
    }
}

 

可以看到单线程条件下，我们做list的插入操作完全没问题，那我们再来模拟并发条件下执行，会出现什么问题。

2 多线程环境下

public static void main(String[] args) {
    // List集合
    List<String> list = new ArrayList<>();
    // 循环插入
    for (int i = 0; i < 10; i++) {
        // 开启线程执行
        new Thread(()->{
            list.add(UUID.randomUUID().toString().substring(0,5));
            System.out.println(list);
        },"线程List").start();

    }
}

 

ArrayList在迭代的时候如果同时对其进行修改就会抛出java.util.ConcurrentModificationException异常，就是并发修改异常。

 

二、解决方案

1.使用Vector类

public static void main(String[] args) {
    // List集合
    List<String> list = new Vector<>();
    // 循环插入
    for (int i = 0; i < 10; i++) {
        // 开启线程执行
        new Thread(()->{
            list.add(UUID.randomUUID().toString().substring(0,5));
            System.out.println(list);
        },"线程List").start();

    }
}

Vector 是同步访问的，它的add方法底层加了synchronized关键字修饰。

 

测试结果：

 

2. 使用Collections.synchronizedList

public static void main(String[] args) {
   // List集合
    List<String> list = Collections.synchronizedList(new ArrayList<>());
    // 循环插入
    for (int i = 0; i < 10; i++) {
        // 开启线程执行
        new Thread(()->{
            list.add(UUID.randomUUID().toString().substring(0,5));
            System.out.println(list);
        },"线程List").start();

    }
}

查看底层源码可以发现他也使用了synchronized关键字修饰。

 

3. 使用并发容器CopyOnWriteArrayList

public static void main(String[] args) {
    // List集合
    List<String> list = new CopyOnWriteArrayList<>();
    // 循环插入
    for (int i = 0; i < 10; i++) {
        // 开启线程执行
        new Thread(()->{
            list.add(UUID.randomUUID().toString().substring(0,5));
            System.out.println(list);
        },"线程List").start();

    }
}

查看源码它使用的是lock锁机制。

 

写入时复制，有多个线程调用的时候，写入的时候，复制一份，避免覆盖造成数据问题。就是在写的时候不对原集合进行修改，而是重新复制一份，修改完之后，再移动指针。

从JDK1.5开始Java并发包里提供了两个使用CopyOnWrite机制实现的并发容器,它们是CopyOnWriteArrayList和CopyOnWriteArraySet。CopyOnWrite容器非常有用，可以在非常多的并发场景中使用到。

解读源码：

/**
 * Appends the specified element to the end of this list.
 *
 * @param e element to be appended to this list
 * @return {@code true} (as specified by {@link Collection#add})
 */
public boolean add(E e) {
    final ReentrantLock lock = this.lock;//可重入锁
    lock.lock();//加锁
    try {
        Object[] elements = getArray();
        int len = elements.length;
        Object[] newElements = Arrays.copyOf(elements, len + 1);//拷贝新数组
        newElements[len] = e;
        setArray(newElements);//将引用指向新数组
        return true;
    } finally {
        lock.unlock();//解锁
    }
}

add()在添加集合的时候加上了锁，保证了同步，避免了多线程写的时候会Copy出N个副本出来。

 

总结

CopyOnWriteArrayList使用场景：读多写少（黑名单，白名单，商品类目的访问和更新场景），集合不大。所以一般来说，我们都会使用JUC包下给我们提供的线程安全容器，而不是使用老一代的线程安全容器。