面试必问之 CopyOnWriteArrayList,你了解多少?

一、摘要

在介绍 CopyOnWriteArrayList 之前,我们一起先来看看如下方法执行结果,代码内容如下:

public static void main(String[] args) {
    List list = new ArrayList();
    list.add("1");
    list.add("2");
    list.add("1");
    System.out.println("原始list元素:"+ list.toString());
    //通过对象移除等于内容为1的元素
    for (String item : list) {
        if("1".equals(item)) {
            list.remove(item);
        }
    }
    System.out.println("通过对象移除后的list元素:"+ list.toString());
}

执行结果内容如下:

原始list元素:[1, 2, 1]
Exception in thread "main" java.util.ConcurrentModificationException
    at java.util.ArrayList$Itr.checkForComodification(ArrayList.java:909)
    at java.util.ArrayList$Itr.next(ArrayList.java:859)
    at com.example.container.a.TestList.main(TestList.java:16)

很遗憾,结果并没有达到我们想要的预期效果,执行之后直接报错!抛ConcurrentModificationException异常!

为啥会抛这个异常呢?

我们一起来看看, foreach写法实际上是对 List.iterator() 迭代器的一种简写,因此我们可以从分析 List.iterator() 迭代器进行入手,看看为啥会抛这个异常。

ArrayList类中的 Iterator迭代器实现,源码内容:

面试必问之 CopyOnWriteArrayList,你了解多少?

通过代码我们发现 ItrArrayList 中定义的一个私有内部类,每次调用 nextremove方法时,都会调用 checkForComodification方法,源码如下:

/**修改次数检查*/
final void checkForComodification() {
    //检查List中的修改次数是否与迭代器类中的修改次数相等
    if (modCount != expectedModCount)
        throw new ConcurrentModificationException();
}

checkForComodification方法,实际上是用来检查 List中的修改次数 modCount是否与迭代器类中的修改次数 expectedModCount相等,如果不相等,就会抛出 ConcurrentModificationException异常!

那么问题基本上已经清晰了,上面的运行结果之所以会抛出这个异常,就是因为 List中的修改次数 modCount与迭代器类中的修改次数 expectedModCount不相同造成的!

阅读过集合源码的朋友,可能想起 Vector 这个类,它不是 JDK 中 ArrayList 线程安全的一个版本么?

好的,为了眼见为实,我们把 ArrayList换成 Vector来测试一下,代码如下:

public static void main(String[] args) {
    Vector list = new Vector();
    //模拟10个线程向list中添加内容,并且读取内容
    for (int i = 0; i < 5; i++) {
        final int j = i;
        new Thread(new Runnable() {
            @Override
            public void run() {
                //添加内容
                list.add(j + "-j");

                //读取内容
                for (String str : list) {
                    System.out.println("内容:" + str);
                }
            }
        }).start();
    }
}

执行程序,运行结果如下:

面试必问之 CopyOnWriteArrayList,你了解多少?

还是一样的结果,抛异常了Vector虽然线程安全,只不过是加了 synchronized关键字,但是迭代问题完全没有解决!

继续回到本文要介绍的 CopyOnWriteArrayList 类,我们把上面的例子,换成 CopyOnWriteArrayList类来试试,源码内容如下:

public static void main(String[] args) {
    //将ArrayList换成CopyOnWriteArrayList
    CopyOnWriteArrayList list = new CopyOnWriteArrayList<>();
    list.add("1");
    list.add("2");
    list.add("1");
    System.out.println("原始list元素:"+ list.toString());

    //通过对象移除等于11的元素
    for (String item : list) {
        if("1".equals(item)) {
            list.remove(item);
        }
    }
    System.out.println("通过对象移除后的list元素:"+ list.toString());
}

执行结果如下:

原始list元素:[1, 2, 1]
通过对象移除后的list元素:[2]

呃呵,执行成功了,没有报错!是不是很神奇~~

当然,类似上面这样的例子有很多,比如写10个线程向 list中添加元素读取内容,也会抛出上面那个异常,操作如下:

public static void main(String[] args) {
    final List list = new ArrayList<>();
    //模拟10个线程向list中添加内容,并且读取内容
    for (int i = 0; i < 10; i++) {
        final int j = i;
        new Thread(new Runnable() {
            @Override
            public void run() {
                //添加内容
                list.add(j + "-j");

                //读取内容
                for (String str : list) {
                    System.out.println("内容:" + str);
                }
            }
        }).start();
    }
}

类似的操作例子就非常多了,这里就不一一举例了。

CopyOnWriteArrayList 实际上是 ArrayList 一个线程安全的操作类!

从它的名字可以看出, CopyOnWrite 是在写入的时候,不修改原内容,而是将原来的内容复制一份到新的数组,然后向新数组写完数据之后,再移动内存指针,将目标指向最新的位置。

二、简介

从 JDK1.5 开始 Java 并发包里提供了两个使用 CopyOnWrite机制实现的并发容器,分别是 CopyOnWriteArrayListCopyOnWriteArraySet

从名字上看, CopyOnWriteArrayList主要针对动态数组,一个线程安全版本的 ArrayList !

CopyOnWriteArraySet主要针对集, CopyOnWriteArraySet可以理解为 HashSet线程安全的操作类,我们都知道 HashSet基于散列表 HashMap实现, 但是 CopyOnWriteArraySet 并不是基于散列表实现,而是基于 CopyOnWriteArrayList 动态数组实现!

关于这一点,我们可以从它的源码中得出结论,部分源码内容:

面试必问之 CopyOnWriteArrayList,你了解多少?

从源码上可以看出, CopyOnWriteArraySet默认初始化的时候,实例化了 CopyOnWriteArrayList类, CopyOnWriteArraySet的大部分方法,例如 addremove等方法都基于 CopyOnWriteArraySet实现!

两者最大的不同点是, CopyOnWriteArrayList可以允许元素重复,而 CopyOnWriteArraySet不允许有重复的元素!

好了,继续来 BB 本文要介绍的 CopyOnWriteArrayList 类~~

打开 CopyOnWriteArrayList类的源码,内容如下:

面试必问之 CopyOnWriteArrayList,你了解多少?

可以看到 CopyOnWriteArrayList 的存储元素的数组 array变量,使用了 volatile关键字保证的多线程下数据可见行;同时,使用了 ReentrantLock可重入锁对象,保证线程操作安全。

在初始化阶段, CopyOnWriteArrayList默认给数组初始化了一个对象,当然,初始化方法还有很多,比如如下我们经常会用到的一个初始化方法,源码内容如下:

面试必问之 CopyOnWriteArrayList,你了解多少?

这个方法,表示如果我们传入的是一个 ArrayList数组对象,会将对象内容复制一份到新的数组中,然后初始化进去,操作如下:

List list = new ArrayList<>();
...

//CopyOnWriteArrayList将list内容复制出来,并创建一个新的数组
CopyOnWriteArrayList copyList = new CopyOnWriteArrayList<>(list);

CopyOnWriteArrayList是对原数组内容进行复制再写入,那么是不是也存在多线程下操作也会发生冲突呢?

下面我们再一起来看看它的方法实现!

三、常用方法

3.1、添加元素

add()方法是 CopyOnWriteArrayList的添加元素的入口!

CopyOnWriteArrayList之所以能保证多线程下安全操作, add()方法功不可没,源码如下:

面试必问之 CopyOnWriteArrayList,你了解多少?

操作步骤如下:

  • 1、获得对象锁;
  • 2、获取数组内容;
  • 3、将原数组内容复制到新数组;
  • 4、写入数据;
  • 5、将array数组变量地址指向新数组;
  • 6、释放对象锁;

在 Java 中,独占锁方面,有2种方式可以保证线程操作安全,一种是使用虚拟机提供的 synchronized来保证并发安全,另一种是使用 JUC包下的 ReentrantLock可重入锁来保证线程操作安全。

CopyOnWriteArrayList使用了 ReentrantLock这种可重入锁,保证了线程操作安全,同时数组变量 array使用 volatile保证多线程下数据的可见行!

其他的,还有指定下标进行添加的方法,如 add(int index, E element),操作类似,先找到需要添加的位置,如果是中间位置,则以添加位置为分界点,分两次进行复制,最后写入数据!

3.2、移除元素

remove()方法是 CopyOnWriteArrayList的移除元素的入口!

源码如下:

面试必问之 CopyOnWriteArrayList,你了解多少?

操作类似添加方法,步骤如下:

  • 1、获得对象锁;
  • 2、获取数组内容;
  • 3、判断移除的元素是否为数组最后的元素,如果是最后的元素,直接将旧元素内容复制到新数组,并重新设置 array值;
  • 4、如果是中间元素,以 index为分界点,分两节复制;
  • 5、将array数组变量地址指向新数组;
  • 6、释放对象锁;

当然,移除的方法还有基于对象的 remove(Object o),原理也是一样的,先找到元素的下标,然后执行移除操作。

3.3、查询元素

get()方法是 CopyOnWriteArrayList的查询元素的入口!

源码如下:

public E get(int index) {
    //获取数组内容,通过下标直接获取
    return get(getArray(), index);
}

查询因为不涉及到数据操作,所以无需使用锁进行处理!

3.4、遍历元素

上文中我们介绍到,基本都是在遍历元素的时候因为修改次数与迭代器中的修改次数不一致,导致检查的时候抛异常,我们一起来看看 CopyOnWriteArrayList迭代器实现。

打开源码,可以得出 CopyOnWriteArrayList返回的迭代器是 COWIterator,源码如下:

public Iterator iterator() {
    return new COWIterator(getArray(), 0);
}

打开 COWIterator类,其实它是 CopyOnWriteArrayList的一个静态内部类,源码如下:

面试必问之 CopyOnWriteArrayList,你了解多少?

可以看出,在使用迭代器的时候,遍历的元素都来自于上面的 getArray()方法传入的对象数组,也就是传递进来的 array 数组!

由此可见,CopyOnWriteArrayList 在使用迭代器遍历的时候,操作的都是原数组,没有像上面那样进行修改次数判断,所以不会抛异常!

当然,从源码上也可以得出, 使用 CopyOnWriteArrayList 的迭代器进行遍历元素的时候,不能调用 remove() 方法移除元素,因为不支持此操作!

如果想要移除元素,只能使用 CopyOnWriteArrayList 提供的 remove() 方法,而不是迭代器的 remove() 方法,这个需要注意一下!

四、总结

CopyOnWriteArrayList是一个典型的读写分离的动态数组操作类!

在写入数据的时候,将旧数组内容复制一份出来,然后向新的数组写入数据,最后将新的数组内存地址返回给数组变量;移除操作也类似,只是方式是移除元素而不是添加元素;而查询方法,因为不涉及线程操作,所以并没有加锁出来!

因为 CopyOnWriteArrayList读取内容没有加锁,在写入数据的时候同时也可以进行读取数据操作,因此性能得到很大的提升,但是也有缺陷, 对于边读边写的情况,不一定能实时的读到最新的数据,比如如下操作:

public static void main(String[] args) throws InterruptedException {
    final CopyOnWriteArrayList list = new CopyOnWriteArrayList<>();
    list.add("a");
    list.add("b");
    for (int i = 0; i < 5; i++) {
        final int j =i;
        new Thread(new Runnable() {
            @Override
            public void run() {
                //写入数据
                list.add("i-" + j);
                //读取数据
                for (String str : list) {
                    System.out.println("线程-" + Thread.currentThread().getName() + ",读取内容:" + str);
                }
            }
        }).start();
    }
}

新建5个线程向 list中添加元素,执行结果如下:

面试必问之 CopyOnWriteArrayList,你了解多少?

可以看到,5个线程的读取内容有差异!

因此 CopyOnWriteArrayList很适合读多写少的应用场景!

五、参考

1、JDK1.7&JDK1.8 源码

2、掘金 – 拥抱心中的梦想 – 说一说Java中的CopyOnWriteArrayList

Original: https://www.cnblogs.com/dxflqm/p/15802092.html
Author: 程序员志哥
Title: 面试必问之 CopyOnWriteArrayList,你了解多少?

原创文章受到原创版权保护。转载请注明出处:https://www.johngo689.com/594217/

转载文章受原作者版权保护。转载请注明原作者出处!

(0)

大家都在看

亲爱的 Coder【最近整理,可免费获取】👉 最新必读书单  | 👏 面试题下载  | 🌎 免费的AI知识星球