CopyOnWriteArrayList的设计思想很是简单,但在设计层面有一些小问题须要注意。java
JDK版本:oracle java 1.8.0_102git
原本不想写的,可是github上CopyOnWriteArrayList的code results也有165k,为了流量仍是写一写吧。github
看两个方法你就懂了。数组
public E get(int index) {
return get(getArray(), index);
}
final Object[] getArray() {
return array;
}
复制代码
get()方法直接调用内部的getArray()方法,而getArray()方法则直接返回成员变量array。安全
我没明白为何要再封装一层,而不是直接访问。数据结构
array指向一个数组,是CopyOnWriteArrayList的内部数据结构:并发
private transient volatile Object[] array;
复制代码
敲黑板!!!oracle
**array是一个volatile变量,**其读、写操做具备Happends-Before关系。具体来说,线程W1经过set()方法“修改”集合后,线程R1能马上经过get()方法获得array的最新值。app
你能够理解为volatile变量的读、写是原子的,不过,我更但愿你能从顺序和可见性的角度理解理解volatile、锁等具备偏序关系的操做。volatile的原理和用法见volatile关键字的做用、原理。性能
重点是set()方法:
public E set(int index, E element) {
final ReentrantLock lock = this.lock;
lock.lock();
try {
Object[] elements = getArray();
E oldValue = get(elements, index);
if (oldValue != element) {
int len = elements.length;
Object[] newElements = Arrays.copyOf(elements, len);
newElements[index] = element;
setArray(newElements);
} else {
// Not quite a no-op; ensures volatile write semantics
setArray(elements);
}
return oldValue;
} finally {
lock.unlock();
}
}
final void setArray(Object[] a) {
array = a;
}
复制代码
set()方法也很简单,两个要点:
按照独占锁的思路,仅仅给写线程加锁是不行的,会有读、写线程的竞争问题。可是get()中明明没有加锁,为何也没有问题呢?
经过加锁,保证同一时间最多只有一个写线程W1进入try block;假设要设置的值与旧值不一样。9-10行首先将数据复制一份(此时,没有其余写线程能进入try block修改集合),11行在副本上修改相应元素,12行修改array引用。array是volatile变量,因此写的最新值对其余读线程、写线程都是可见的。
这就是所谓的“写时复制
”。
实际上,15行的volatile写是多余的。这只是为了能从代码里理解到volatile写的语义,并没必要要的保证什么——不过这种考虑也是不恰当的,反而使代码迷惑。一个相似的例子是addIfAbsent():
public boolean addIfAbsent(E e) {
Object[] snapshot = getArray();
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) {
// Optimize for lost race to another addXXX operation
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;
}
Object[] newElements = Arrays.copyOf(current, len + 1);
newElements[len] = e;
setArray(newElements);
return true;
} finally {
lock.unlock();
}
}
复制代码
基本思想相同,1七、19行都是直接返回,并无作多余的“volatile写”。
在网上搜的话,还有不少其余观点。若是你认为个人观点是错误的,欢迎交流。
addIfAbsent的编码风格跟set()区别很大,不像一我的写的。须要认识到,JDK是一个发展、变化的产品,一个包、甚至一个类均可能不是同一我的、同一段时间写的,编码风格、设计思想可能发生变化;更不要假定JDK的实现必定是对的(固然,绝大部分时候是对的),要基于正确的逻辑去分析,再作判断。
TODO 20171024
看起来,若是不给set加锁,彷佛并发性能更高,一致性也没有削弱多少。未解决,欢迎交流。
最后总结CopyOnWriteArrayList的设计思想:
本文连接:源码|并发一枝花之CopyOnWriteArrayList
做者:猴子007
出处:monkeysayhi.github.io
本文基于 知识共享署名-相同方式共享 4.0 国际许可协议发布,欢迎转载,演绎或用于商业目的,可是必须保留本文的署名及连接。