CopyOnWriteArrayList 源码详解

目录

一. 前言

二. 源码详解

2.1. 类结构

2.2. 属性

2.3. 构造方法

2.4. add(E e)

2.5. add(int index, E element)

2.6. addIfAbsent() 方法

2.7. 获取元素() 方法

2.8. remove(int index)

2.9. size()

三. FAQ

3.1. 为什么CopyOnWriteArrayList没有size属性？

四. 总结

一. 前言

    CopyOnWriteArrayList 是 ArrayList 的线程安全版本，内部也是通过数组实现，每次对数组的修改都完全拷贝一份新的数组来修改，修改完了再替换掉老数组，这样保证了只阻塞写操作，不阻塞读操作，实现读写分离。

    在 ArrayList 的类注释上，JDK 就提醒了我们，如果要把 ArrayList 作为共享变量的话，是线程不安全的，推荐我们自己加锁或者使用 Collections.synchronizedList() 方法，其实 JDK 还提供了另外一种线程安全的 List，叫做 CopyOnWriteArrayList。

二. 源码详解

2.1. 类结构

public class CopyOnWriteArrayList<E>implements List<E>, RandomAccess, Cloneable, java.io.Serializable {......
}

CopyOnWriteArrayList实现了List，RandomAccess，Cloneable，java.io.Serializable等接口。
CopyOnWriteArrayList实现了List，提供了基础的添加、删除、遍历等操作。
CopyOnWriteArrayList实现了RandomAccess，提供了随机访问的能力。
CopyOnWriteArrayList实现了Cloneable，可以被克隆。
CopyOnWriteArrayList实现了Serializable，可以被序列化。

2.2. 属性

/** 用于修改时加锁 */
final transient ReentrantLock lock = new ReentrantLock();/** 真正存储元素的地方，只能通过getArray()/setArray()访问 */
private transient volatile Object[] array;

lock：修改时加锁，使用 transient 修饰表示不自动序列化。
array：存储元素的地方，使用 transient 修饰表示不自动序列化，使用 volatile 修饰表示一个线程对这个字段的修改另外一个线程立即可见。

2.3. 构造方法

final void setArray(Object[] a) {array = a;
}public CopyOnWriteArrayList() {// 所有对array的操作都是通过setArray()和getArray()进行setArray(new Object[0]);
}public CopyOnWriteArrayList(Collection<? extends E> c) {Object[] elements;if (c.getClass() == CopyOnWriteArrayList.class)// 如果c也是CopyOnWriteArrayList类型// 那么直接把它的数组拿过来使用elements = ((CopyOnWriteArrayList<?>)c).getArray();else {// 否则调用其toArray()方法将集合元素转化为数组elements = c.toArray();// 这里c.toArray()返回的不一定是Object[]类型// 详细原因见ArrayList里面的分析if (elements.getClass() != Object[].class)elements = Arrays.copyOf(elements, elements.length, Object[].class);}setArray(elements);
}public CopyOnWriteArrayList(E[] toCopyIn) {setArray(Arrays.copyOf(toCopyIn, toCopyIn.length, Object[].class));
}

1. 如果 c 是CopyOnWriteArrayList类型，直接把它的数组赋值给当前list的数组，注意这里是浅拷贝，两个集合共用同一个数组。
2. 如果 c 不是CopyOnWriteArrayList类型，则进行拷贝把c的元素全部拷贝到当前list的数组中。
3. 把toCopyIn的元素拷贝给当前list的数组。

2.4. add(E e)

public boolean add(E e) {final ReentrantLock lock = this.lock;// 加锁lock.lock();try {// 获取旧数组Object[] elements = getArray();int len = elements.length;// 将旧数组元素拷贝到新数组中// 新数组大小是旧数组大小加1Object[] newElements = Arrays.copyOf(elements, len + 1);// 将元素放在最后一位newElements[len] = e;setArray(newElements);return true;} finally {// 释放锁lock.unlock();}
}

源码说明：
1. 加锁；
2. 获取元素数组；
3. 新建一个数组，大小为原数组长度加1，并把原数组元素拷贝到新数组；
4. 把新添加的元素放到新数组的末尾；
5. 把新数组赋值给当前对象的array属性，覆盖原数组；
6. 解锁。

2.5. add(int index, E element)

添加一个元素在指定索引处。

public void add(int index, E element) {final ReentrantLock lock = this.lock;// 加锁lock.lock();try {// 获取旧数组Object[] elements = getArray();int len = elements.length;// 检查是否越界, 可以等于lenif (index > len || index < 0)throw new IndexOutOfBoundsException("Index: "+index+", Size: "+len);Object[] newElements;int numMoved = len - index;if (numMoved == 0)// 如果插入的位置是最后一位// 那么拷贝一个n+1的数组, 其前n个元素与旧数组一致newElements = Arrays.copyOf(elements, len + 1);else {// 如果插入的位置不是最后一位// 那么新建一个n+1的数组newElements = new Object[len + 1];// 拷贝旧数组前index的元素到新数组中System.arraycopy(elements, 0, newElements, 0, index);// 将index及其之后的元素往后挪一位拷贝到新数组中// 这样正好index位置是空出来的System.arraycopy(elements, index, newElements, index + 1,numMoved);}// 将元素放置在index处newElements[index] = element;setArray(newElements);} finally {// 释放锁lock.unlock();}
}

源码说明：
1. 加锁；
2. 检查索引是否合法，如果不合法抛出IndexOutOfBoundsException异常，注意这里 index 等于 len 也是合法的；
3. 如果索引等于数组长度（也就是数组最后一位再加1），那就拷贝一个len+1的数组；
4. 如果索引不等于数组长度，那就新建一个len+1的数组，并按索引位置分成两部分，索引之前（不包含）的部分拷贝到新数组索引之前（不包含）的部分，索引之后（包含）的位置拷贝到新数组索引之后（不包含）的位置，索引所在位置留空；
5. 把索引位置赋值为待添加的元素；
6. 把新数组赋值给当前对象的array属性，覆盖原数组；
7. 解锁。

2.6. addIfAbsent() 方法

添加一个元素如果这个元素不存在于集合中。

public boolean addIfAbsent(E e) {// 获取元素数组, 取名为快照Object[] snapshot = getArray();// 检查如果元素不存在,直接返回false// 如果存在再调用addIfAbsent()方法添加元素return indexOf(e, snapshot, 0, snapshot.length) >= 0 ? false :addIfAbsent(e, snapshot);
}private boolean addIfAbsent(E e, Object[] snapshot) {final ReentrantLock lock = this.lock;// 加锁lock.lock();try {// 重新获取旧数组Object[] current = getArray();int len = current.length;// 如果快照与刚获取的数组不一致// 说明有修改if (snapshot != current) {// 重新检查元素是否在刚获取的数组里int common = Math.min(snapshot.length, len);for (int i = 0; i < common; i++)// 到这个方法里面了, 说明元素不在快照里面if (current[i] != snapshot[i] && eq(e, current[i]))return false;if (indexOf(e, current, common, len) >= 0)return false;}// 拷贝一份n+1的数组Object[] newElements = Arrays.copyOf(current, len + 1);// 将元素放在最后一位newElements[len] = e;setArray(newElements);return true;} finally {// 释放锁lock.unlock();}
}

源码说明：
1. 检查这个元素是否存在于数组快照中；
2. 如果存在直接返回 false，如果不存在调用addIfAbsent(E e, Object[] snapshot)处理;
3. 加锁；
4. 如果当前数组不等于传入的快照，说明有修改，检查待添加的元素是否存在于当前数组中，如果存在直接返回false;
5. 拷贝一个新数组，长度等于原数组长度加1，并把原数组元素拷贝到新数组中；
6. 把新元素添加到数组最后一位；
7. 把新数组赋值给当前对象的array属性，覆盖原数组；
8. 解锁；

2.7. 获取元素() 方法

获取指定索引的元素，支持随机访问，时间复杂度为O(1)。

final Object[] getArray() {return array;
}public E get(int index) {// 获取元素不需要加锁// 直接返回index位置的元素// 这里是没有做越界检查的, 因为数组本身会做越界检查return get(getArray(), index);
}private E get(Object[] a, int index) {return (E) a[index];
}

源码说明：
1. 获取元素数组；
2. 返回数组指定索引位置的元素；

2.8. remove(int index)

删除指定索引位置的元素。

public E remove(int index) {final ReentrantLock lock = this.lock;// 加锁lock.lock();try {// 获取旧数组Object[] elements = getArray();int len = elements.length;E oldValue = get(elements, index);int numMoved = len - index - 1;if (numMoved == 0)// 如果移除的是最后一位// 那么直接拷贝一份n-1的新数组, 最后一位就自动删除了setArray(Arrays.copyOf(elements, len - 1));else {// 如果移除的不是最后一位// 那么新建一个n-1的新数组Object[] newElements = new Object[len - 1];// 将前index的元素拷贝到新数组中System.arraycopy(elements, 0, newElements, 0, index);// 将index后面(不包含)的元素往前挪一位// 这样正好把index位置覆盖掉了, 相当于删除了System.arraycopy(elements, index + 1, newElements, index,numMoved);setArray(newElements);}return oldValue;} finally {// 释放锁lock.unlock();}
}

源码说明：
1. 加锁；
2. 获取指定索引位置元素的旧值；
3. 如果移除的是最后一位元素，则把原数组的前len-1个元素拷贝到新数组中，并把新数组赋值给当前对象的数组属性；
4. 如果移除的不是最后一位元素，则新建一个len-1长度的数组，并把原数组除了指定索引位置的元素全部拷贝到新数组中，并把新数组赋值给当前对象的数组属性；
5. 解锁并返回旧值；

2.9. size()

返回数组的长度。

public int size() {// 获取元素个数不需要加锁// 直接返回数组的长度return getArray().length;
}

三. FAQ

3.1. 为什么CopyOnWriteArrayList没有size属性？

    因为每次修改都是拷贝一份正好可以存储目标个数元素的数组，所以不需要size属性了，数组的长度就是集合的大小，而不像ArrayList数组的长度实际是要大于集合的大小的。比如，add(E e) 操作，先拷贝一份 n+1 个元素的数组，再把新元素放到新数组的最后一位，这时新数组的长度为len+1 了，也就是集合的size了。

四. 总结

1. CopyOnWriteArrayList使用ReentrantLock重入锁加锁，保证线程安全；
2. CopyOnWriteArrayList的写操作都要先拷贝一份新数组，在新数组中做修改，修改完了再用新数组替换老数组，所以空间复杂度是O(n)，性能比较低下；
3. CopyOnWriteArrayList的读操作支持随机访问，时间复杂度为O(1)；
4. CopyOnWriteArrayList采用读写分离的思想，读操作不加锁，写操作加锁，且写操作占用较大内存空间，所以适用于读多写少的场合；
5. CopyOnWriteArrayList只保证最终一致性，不保证实时一致性。

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.hqwc.cn/news/176721.html

如若内容造成侵权/违法违规/事实不符，请联系编程知识网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

LeetCode【215】数组中第k大的元素

LeetCode【215】数组中第k大的元素

题目&#xff1a; 思路&#xff1a; https://zhuanlan.zhihu.com/p/59110615 代码&#xff1a; public int findKthLargest(int[] nums, int k) {PriorityQueue<Integer> queue new PriorityQueue<>((o1, o2) -> o1 - o2);for (int i 0; i < nums.lengt…
阅读更多...
排他思想小练习

排他思想小练习

点击 某个按钮&#xff0c;让某个按钮对应的 ul 显示&#xff0c;其他的ul 都隐藏 1 -找到所有的按钮 &#xff0c;并循环 2 -给按钮添加点击事件 3 -点击的时候 获取的对应的按钮 获取按钮对应的下标 4 - 所有的都变为黑 点击的按钮颜色变为红色 5 - 其他的所有ul 都隐…
阅读更多...
STC89C52+HX711完成电子秤设计

STC89C52+HX711完成电子秤设计

一、项目背景 电子秤是一种通过传感器测量物体质量的设备&#xff0c;被广泛应用于商业和工业领域。传统的机械秤已经逐渐被电子秤取代&#xff0c;因为电子秤具有更高的精度、更方便的使用和更多的功能。 本项目利用STC89C52单片机和HX711模块完成电子秤设计&#xff0c;具有…
阅读更多...
Axure9基本操作

Axure9基本操作

产品经理零基础入门&#xff08;四&#xff09;Axure 原型图教程&#xff0c;2小时学会_哔哩哔哩_bilibili Axure 9 从入门到精通全集&#xff0c;自学必备_哔哩哔哩_bilibili 1. ① 页面对应页面个数&#xff0c;概要对应每个页面的具体内容 ② 文件类型 ③ 备用间隔改为5分…
阅读更多...
没有设计经验的新手如何制作一本电子画册？

没有设计经验的新手如何制作一本电子画册？

移动信息时代&#xff0c;电子画册逐渐取代纸质画册&#xff0c;它无需印刷&#xff0c;环保节能&#xff0c;也无需随身携带&#xff0c;通过手机/平板/电脑等设备即可随时在线浏览阅读&#xff0c;十分方便。那没有设计经验的新手如何制作一本这样随身携带方便的电子画册呢&a…
阅读更多...
Android WebView专题

Android WebView专题

WebView 专题 第一个WebView程序&#xff1a;加载远程网址 Layout添加WebView组件&#xff1b; <WebViewandroid:id"id/webView_first"android:layout_width"match_parent"android:layout_height"match_parent"/>初始化组件&#xff0c;加…
阅读更多...
理工ubuntu20.04电脑配置记录

理工ubuntu20.04电脑配置记录

8188gu无线网卡配置 首先下载github上的文件&#xff0c;进入文件夹 安装make命令 1. 查看usb无线网卡 sudo lsusb|grep 8188 2. 环境准备 sudo apt-get install git make build-essential git dkms linux-headers-$(uname -r) 3. 编译安装 git clone https://github.com…
阅读更多...
揭秘拍卖竞价源码的前沿技术：加密、智能合约与更多

揭秘拍卖竞价源码的前沿技术：加密、智能合约与更多

在数字时代的今天&#xff0c;拍卖竞价源码成为了炙手可热的话题。作为该领域的专家&#xff0c;我将带您深入了解这一前沿技术的奥秘。本文将揭示拍卖竞价源码的工作原理、加密技术的应用、智能合约的作用以及其他相关技术。 2. 拍卖竞价源码的工作原理 拍卖竞价源码是一种用…
阅读更多...
搭建项目环境，集成ts和jest

搭建项目环境，集成ts和jest

前言 开新坑。 斥巨资购入大崔哥的 mini-vue 课程&#xff0c;为了改变自己东一榔头西一棒槌的学习状态&#xff0c;也是因为深刻思考了自己身无长物浑浑噩噩这么多年只会敲代码&#xff0c;别无出路&#xff0c;也只能提升自己继续走技术这条路&#xff0c;那提高技术绕不过…
阅读更多...
CTFhub-RCE-远程包含

CTFhub-RCE-远程包含

给咱一个phpinfo那么必然有他的道理 PHP的配置选项allow_url_include为ON的话&#xff0c;则include/require函数可以加载远程文件&#xff0c;这种漏洞被称为"远程文件包含漏洞(Remote File Inclusion RFI)"。 allow_url_fopen On 是否允许打开远程文件 allow_u…
阅读更多...
ESP32网络开发实例-将数据保存到InfluxDB时序数据库

ESP32网络开发实例-将数据保存到InfluxDB时序数据库

将数据保存到InfluxDB时序数据库 文章目录 将数据保存到InfluxDB时序数据库1、InfluxDB介绍与安装3、软件准备4、硬件准备5、代码实现6、InfluxDB数据可视化在本文中，将介绍 InfluxDB 以及如何将其与 ESP32 开发板一起使用。 我们将向展示如何创建数据库桶并将 ESP32 数据发送…
阅读更多...
V10chrony服务配置

V10chrony服务配置

Chrony简介 Chrony是一个开源自由的网络时间协议 NTP 的客户端和服务器软软件。它能让计算机保持系统时钟与时钟服务器&#xff08;NTP&#xff09;同步&#xff0c;因此让你的计算机保持精确的时间&#xff0c;Chrony也可以作为服务端软件为其他计算机提供时间同步服务。 Ch…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023