1、CopyOnWriteArrayList介绍
CopyOnWriteArrayList 是一个线程安全的ArrayList。
CopyOnWriteArrayList 是基于Lock锁和线程副本的形式来保证线程安全的,
在写数据时,先获取Lock锁,然后复制一个副本,添加数据时,是往副本数组中添加数据,最 后再将副本数组赋值给自身array属性,这样可以保证读写分离(读写完全独立),从而提高 读写性能
CopyOnWriteArrayList 是弱一致性的,写操作先操作,但是副本还没落CopyOnWriteArrayList 的 array属性中,此时读操作是无法读取刚写入的数据的。
注意:
CopyOnWriteArrayList 每次写操作都要复制一个副本,若业务场景是写多多少,并且数 据量比较大时,则尽量避免使用 CopyOnWriteArrayList;因为这里会创建大量的数组副 本,比较占用内存资源;数组数据量很大时,数组的复制也是很消耗内存资源的
2、核心属性&方法
CopyOnWriteArrayList 比较简单,只看下2个属性,2个设置array属性的方法及1个无参构造
函数就行了,如下所示:
//lock锁,写操作时先获取锁
final transient ReentrantLock lock = new ReentrantLock();
//真正保存数据的数组
private transient volatile Object[] array;
/**
* 获取array属性
*/
final Object[] getArray() {
return array;
}
/**
* 替换array属性
*/
final void setArray(Object[] a) {
array = a;
}
public CopyOnWriteArrayList() {
//默认数组长度为0
//因为每次写数据时,都会构建一个全新的数组,所以在 CopyOnWriteArrayList 中也没有数组扩容的操作
setArray(new Object[0]);
}
3、读操作
CopyOnWriteArrayList 读操作就是执行get方法,通过数组的索引位置来获取数据;
具体方法如下:
4、写操作
CopyOnWriteArrayList 写操作是基于Lock 锁+数组副本来保证写操作的线程安全的;
且与读操作隔离,相互独立,互不影响。
写操作方法如下:
4.1)add(E e) 方法
默认在副本数组的末尾添加数据
/**
* 添加数据,不指定索引位置,默认是在最后边添加数据
*/
public boolean add(E e) {
final ReentrantLock lock = this.lock;
//获取锁
lock.lock();
try {
//构建array属性的副本
Object[] elements = getArray();
int len = elements.length;
//创建新的数组,并将副本elements 的数据赋值到 newElements 中
Object[] newElements = Arrays.copyOf(elements, len + 1);
//添加数据,在最后添加
newElements[len] = e;
//将 newElements 赋值给array属性
setArray(newElements);
return true;
} finally {
//释放锁
lock.unlock();
}
}
4.2)add(E e,int index) 方法
在指定索引位置index处添加数组,但不会覆盖索引index原有的数据
/**
* 在指定位置index处添加数据,但不会覆盖数据
*/
public void add(int index, E element) {
final ReentrantLock lock = this.lock;
//加锁
lock.lock();
try {
//获取array属性的值,即复制 array 副本
Object[] elements = getArray();
int len = elements.length;
//判断索引位置是否合法 0<= index <= len
if (index > len || index < 0)
throw new IndexOutOfBoundsException("Index: "+index+
", Size: "+len);
Object[] newElements;
int numMoved = len - index;
if (numMoved == 0) //表示新数据需要放到当前数组的最后边
newElements = Arrays.copyOf(elements, len + 1);
else {//表示当前数据需要放到索引在[0,len-1] 的范围内
//创建新的数组,长度是array属性长度加1
newElements = new Object[len + 1];
//将老数组elements的[0,index) 位置的数据复制到新数组 newElements 的[0,index)处
System.arraycopy(elements, 0, newElements, 0, index);
//将老数组elements的[index,len) 位置的数据复制到新数组 newElements 的[index+1,len]处
System.arraycopy(elements, index, newElements, index + 1,
numMoved);
}
//数据正常放到索引位置index处
newElements[index] = element;
setArray(newElements);
} finally {
//释放锁
lock.unlock();
}
}
5、移除数据
CopyOnWriteArrayList 移除数据有2种情况,一是根据索引index删除,二是删除指定数据,若
数据不存在,则返回null
5.1、remove(int index):据索引index删除指定位置的数据
public E remove(int index) {
final ReentrantLock lock = this.lock;
//加锁
lock.lock();
try {
//获取array属性值
Object[] elements = getArray();
int len = elements.length;
//获取指定索引位置index处的值
E oldValue = get(elements, index);
//删除数据的位置
int numMoved = len - index - 1;
if (numMoved == 0) //要删除的位置是数组最后的一个数据
setArray(Arrays.copyOf(elements, len - 1));
else {
//创建新的数组
Object[] newElements = new Object[len - 1];
//删除数据
//将旧数组 elements 的[0,index)处的数据复制到新数组 newElements 的[0,index)处
System.arraycopy(elements, 0, newElements, 0, index);
//将旧数组 elements 的[index+1,len)处的数据复制到新数组 newElements 的[index,len-1)处
System.arraycopy(elements, index + 1, newElements, index,
numMoved);
//设置array属性
setArray(newElements);
}
//返回删除的数据
return oldValue;
} finally {
lock.unlock();
}
}
5.2、remove(Object o):删除指定的数据
public boolean remove(Object o) {
//获取array的副本
Object[] snapshot = getArray();
//获取要删除数据的位置索引,若数据不存在,则返回-1
//todo 注意:若是并发场景下,这里获取到的数据o的位置index不一定正确
int index = indexOf(o, snapshot, 0, snapshot.length);
return (index < 0) ? false : remove(o, snapshot, index);
}
private boolean remove(Object o, Object[] snapshot, int index) {
final ReentrantLock lock = this.lock;
//加锁
lock.lock();
try {
//新获取array的副本
Object[] current = getArray();
int len = current.length;
// findIndex 是if 代码块的名称
// snapshot != current 表示并发下array已经被其他线程修改了,
// 那么参数传递来的删除数据o的位置index也不正确,需要重新获取index
if (snapshot != current) findIndex: {
//若 index>len :则说明array被其他线程删除了index之后的数据
//index<= len: 则表示array可能新增、删除了数据
int prefix = Math.min(index, len);
for (int i = 0; i < prefix; i++) {
//current[i] != snapshot[i]:表示数组array在并发下发生了改变
//eq(o, current[i]):判断当前i位置的数据与要删除的数据o是否一致,若一致,则将i赋值给index
if (current[i] != snapshot[i] && eq(o, current[i])) {
index = i;
//退出if块
break findIndex;
}
}
//如果for循环结束还没找到要删除的数据,则表示数组array发生了改变
//删除数据不存在
if (index >= len)
return false;
//判断当前index位置的数据是否是要删除的数据,若是,则跳出if 代码块 findIndex
if (current[index] == o)
break findIndex;
//重新查找删除数据o的索引位置
index = indexOf(o, current, index, len);
//没找到
if (index < 0)
return false;
}
//删除数据
Object[] newElements = new Object[len - 1];
System.arraycopy(current, 0, newElements, 0, index);
System.arraycopy(current, index + 1,
newElements, index,
len - index - 1);
//设置array属性
setArray(newElements);
return true;
} finally {
//释放锁
lock.unlock();
}
}