关于java:List集合多线程并发条件下不安全如何解决

37次阅读

共计 2355 个字符,预计需要花费 6 分钟才能阅读完成。

前言

在日常开发过程中,List 是咱们罕用的汇合,比方查询数据库内容返回值比会用一个汇合来装,然而在多线程并发的条件下,会呈现平安问题吗?上面咱们就来测试一下,如果呈现平安问题,该如何解决.

一、List 汇合应用模仿并发测试

1.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 的插入操作齐全没问题,上面咱们来模仿并发条件下执行,会呈现什么问题。

1.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 异样,就是并发批改异样。

二、解决方案

2.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.1 应用 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 关键字润饰。

2.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 包下给咱们提供的线程平安容器,而不是应用老一代的线程平安容器。

正文完
 0