目录一.CpoyOnWriteArrayList 原理简单概述二. CopyOnWriteArrayList 源码分析2.1 属性构造器解读2.2 get 方法分析2.3 add 方法分析2.4 set 方法分析2.5 remove 方法分析三. 总结概括使用过 ArrayList 集合的同学应该大致都知道ArrayList 是一个非线程安全的集合同样Java也为我们提供了线程安全的 List 集合它就是我们本篇文章要说的 CopyOnWriteArrayList。只是因为开发过程中通常会使用其他的的方式保证线程安全所以它使用的频率没有 ArrayList 那么频繁。一.CpoyOnWriteArrayList 原理简单概述CopyOnWriteArrayList 的底层采用了加锁的方式保证线程安全并且加的是 Lock 锁而不是 Sychonized 锁。假如现在有两个线程一个读线程A一个写线程B同时想要想数组中添加元素读线A程就会读取当前内存中 CopyOnWriteArrayList 集合写线程B则是会将内存中的 CopyOnWriteArrayList 集合对象复制一份新的在新复制的集合中执行添加操作添加操作完成之后再将新的集合赋值给原来老的集合并且这个过程中写线程B会获取唯一的 Lock 锁其它写线程会阻塞等待实现读写分离。那么假如说有第三个写线程C也想要执行写数据操作就需要等待写线程B操作完成之后释放 Lock 锁自己获取到 Lock 锁之后才能去执行写入操作。二. CopyOnWriteArrayList 源码分析2.1 属性构造器解读下面是我粘贴的一部分属性getset方法构造方法。1可以看到在 CopyOnWriteArrayList 内部它定义了一个 Lock 锁对象2底层定义了一个名为 array 的对象数组3无参构造可以看出调用无参构造会将 array 数组对象的长度设置为 0只有在进行存储元素的时候才回去扩容public class CopyOnWriteArrayListE implements ListE, RandomAccess, Cloneable, java.io.Serializable { private static final long serialVersionUID 8673264195747942595L; /** The lock protecting all mutators */ final transient ReentrantLock lock new ReentrantLock(); /** The array, accessed only via getArray/setArray. */ private transient volatile Object[] array; /** * Gets the array. Non-private so as to also be accessible * from CopyOnWriteArraySet class. */ final Object[] getArray() { return array; } /** * Sets the array. */ final void setArray(Object[] a) { array a; } /** * Creates an empty list. */ public CopyOnWriteArrayList() { setArray(new Object[0]); }2.2 get 方法分析下面是 CopyOnWriteArrayList 的 get 获取元素的方法这里它 index 和数组的长度大小都没有做判断所以很有可能会出现索引越界异常get 获取元素的方法很简单没有出现加锁的行为public E get(int index) { // 直接返回对象 index 位置的元素 return get(getArray(), index); }2.3 add 方法分析public void add(int index, E element) { // 获取 Lock 锁 final ReentrantLock lock this.lock; // 调用方法上锁 lock.lock(); try { // 获取内存的数组对象并赋值为 elements Object[] elements getArray(); // 定义一个变量 len 获取数组的长度 int len elements.length; // 判断方法的参数 index 是否越界或合法 if (index len || index 0) throw new IndexOutOfBoundsException(Index: index , Size: len); // 定义一个新数组对象 newElements Object[] newElements; // 定义一个变量 numMoved 接收数组长度 - index 的值 int numMoved len - index; // 如果 numMoved 为0则说明要把新添加的元素放在数组的最后 if (numMoved 0) // 调用调用 copyOf 方法将原来数组中的数据全部复制到 newElements中 // 并在数组末尾添加上新的元素 newElements Arrays.copyOf(elements, len 1); else { // 如果 numMoved 不为0则说明要将该元素添加在数组中间的某个位置 // 先将新数组的长度 1 newElements new Object[len 1]; // 将老数组 0~index 之间的数据全部复制到新数组中 System.arraycopy(elements, 0, newElements, 0, index); // 再将 index~数组最后的数据全部复制到新数组中 System.arraycopy(elements, index, newElements, index 1, numMoved); } // 将要添加的元素 element 添加到新数组的 index 的位置 newElements[index] element; // 将老数组地址值赋值给新数组对象 setArray(newElements); } finally { // 操作完毕最后释放锁 lock.unlock(); } }2.4 set 方法分析public E set(int index, E element) { // 获取 Lock 锁 final ReentrantLock lock this.lock; // 调用方法上锁 lock.lock(); try { // 获取内存的数组对象并赋值给一个新的数组对象 elements Object[] elements getArray(); // 获取 index 处的元素 E oldValue get(elements, index); // 判断 oldValue 和要插入的元素是否相等 if (oldValue ! element) { // 获取数组的长度 int len elements.length; // 将原本的数组数据复制到新数组 newElements 中 Object[] newElements Arrays.copyOf(elements, len); // 将 element 放置到新数组的 index 处 newElements[index] element; // 将新数组覆盖原来的数组 setArray(newElements); } else { // Not quite a no-op; ensures volatile write semantics // 进入 else 说明要set的元素在数组中已经存在直接返回原数组 setArray(elements); } // 返回位置 index 处的老的元素 return oldValue; } finally { // 操作完成释放 lock 锁 lock.unlock(); } }2.5 remove 方法分析public E remove(int index) { final ReentrantLock lock this.lock; lock.lock(); try { Object[] elements getArray(); // 获取数组长度 int len elements.length; // 获取 index 处的元素 E oldValue get(elements, index); // 定义 numMoved 计算出要移动的元素的数量 int numMoved len - index - 1; // 如果 numMoved 为0说明要删除的元素恰好是数组的最后一个元素 if (numMoved 0) // 覆盖原来的数组 setArray(Arrays.copyOf(elements, len - 1)); else // numMoved 不为0则定义一个新数组长度为原来的数组长度-1 Object[] newElements new Object[len - 1]; // 将 0~index 处的元素复制到新数组中去 System.arraycopy(elements, 0, newElements, 0, index); // 将 index1~数组最后的元素移动到新数组中 System.arraycopy(elements, index 1, newElements, index, numMoved); // 覆盖原来的数组 setArray(newElements); } // 返回删除的元素值 return oldValue; } finally { // 操作完毕释放 lock 锁 lock.unlock(); } }三. 总结概括经过上面对 add 添加方法get 获取方法set 修改方法remove 删除方法的分析其实也可以看出相比于原来 ArrayList 集合的基础上添加了一把 lock 。在做增改删三种操作的时候搭配上 copy 复制数组的思想就可以做到线程安全这就是 CopyOnWriteArrayList 线程安全的核心设计思想不算特别难理解。
从源码看 CopyOnWriteArrayList 的线程安全机制
目录一.CpoyOnWriteArrayList 原理简单概述二. CopyOnWriteArrayList 源码分析2.1 属性构造器解读2.2 get 方法分析2.3 add 方法分析2.4 set 方法分析2.5 remove 方法分析三. 总结概括使用过 ArrayList 集合的同学应该大致都知道ArrayList 是一个非线程安全的集合同样Java也为我们提供了线程安全的 List 集合它就是我们本篇文章要说的 CopyOnWriteArrayList。只是因为开发过程中通常会使用其他的的方式保证线程安全所以它使用的频率没有 ArrayList 那么频繁。一.CpoyOnWriteArrayList 原理简单概述CopyOnWriteArrayList 的底层采用了加锁的方式保证线程安全并且加的是 Lock 锁而不是 Sychonized 锁。假如现在有两个线程一个读线程A一个写线程B同时想要想数组中添加元素读线A程就会读取当前内存中 CopyOnWriteArrayList 集合写线程B则是会将内存中的 CopyOnWriteArrayList 集合对象复制一份新的在新复制的集合中执行添加操作添加操作完成之后再将新的集合赋值给原来老的集合并且这个过程中写线程B会获取唯一的 Lock 锁其它写线程会阻塞等待实现读写分离。那么假如说有第三个写线程C也想要执行写数据操作就需要等待写线程B操作完成之后释放 Lock 锁自己获取到 Lock 锁之后才能去执行写入操作。二. CopyOnWriteArrayList 源码分析2.1 属性构造器解读下面是我粘贴的一部分属性getset方法构造方法。1可以看到在 CopyOnWriteArrayList 内部它定义了一个 Lock 锁对象2底层定义了一个名为 array 的对象数组3无参构造可以看出调用无参构造会将 array 数组对象的长度设置为 0只有在进行存储元素的时候才回去扩容public class CopyOnWriteArrayListE implements ListE, RandomAccess, Cloneable, java.io.Serializable { private static final long serialVersionUID 8673264195747942595L; /** The lock protecting all mutators */ final transient ReentrantLock lock new ReentrantLock(); /** The array, accessed only via getArray/setArray. */ private transient volatile Object[] array; /** * Gets the array. Non-private so as to also be accessible * from CopyOnWriteArraySet class. */ final Object[] getArray() { return array; } /** * Sets the array. */ final void setArray(Object[] a) { array a; } /** * Creates an empty list. */ public CopyOnWriteArrayList() { setArray(new Object[0]); }2.2 get 方法分析下面是 CopyOnWriteArrayList 的 get 获取元素的方法这里它 index 和数组的长度大小都没有做判断所以很有可能会出现索引越界异常get 获取元素的方法很简单没有出现加锁的行为public E get(int index) { // 直接返回对象 index 位置的元素 return get(getArray(), index); }2.3 add 方法分析public void add(int index, E element) { // 获取 Lock 锁 final ReentrantLock lock this.lock; // 调用方法上锁 lock.lock(); try { // 获取内存的数组对象并赋值为 elements Object[] elements getArray(); // 定义一个变量 len 获取数组的长度 int len elements.length; // 判断方法的参数 index 是否越界或合法 if (index len || index 0) throw new IndexOutOfBoundsException(Index: index , Size: len); // 定义一个新数组对象 newElements Object[] newElements; // 定义一个变量 numMoved 接收数组长度 - index 的值 int numMoved len - index; // 如果 numMoved 为0则说明要把新添加的元素放在数组的最后 if (numMoved 0) // 调用调用 copyOf 方法将原来数组中的数据全部复制到 newElements中 // 并在数组末尾添加上新的元素 newElements Arrays.copyOf(elements, len 1); else { // 如果 numMoved 不为0则说明要将该元素添加在数组中间的某个位置 // 先将新数组的长度 1 newElements new Object[len 1]; // 将老数组 0~index 之间的数据全部复制到新数组中 System.arraycopy(elements, 0, newElements, 0, index); // 再将 index~数组最后的数据全部复制到新数组中 System.arraycopy(elements, index, newElements, index 1, numMoved); } // 将要添加的元素 element 添加到新数组的 index 的位置 newElements[index] element; // 将老数组地址值赋值给新数组对象 setArray(newElements); } finally { // 操作完毕最后释放锁 lock.unlock(); } }2.4 set 方法分析public E set(int index, E element) { // 获取 Lock 锁 final ReentrantLock lock this.lock; // 调用方法上锁 lock.lock(); try { // 获取内存的数组对象并赋值给一个新的数组对象 elements Object[] elements getArray(); // 获取 index 处的元素 E oldValue get(elements, index); // 判断 oldValue 和要插入的元素是否相等 if (oldValue ! element) { // 获取数组的长度 int len elements.length; // 将原本的数组数据复制到新数组 newElements 中 Object[] newElements Arrays.copyOf(elements, len); // 将 element 放置到新数组的 index 处 newElements[index] element; // 将新数组覆盖原来的数组 setArray(newElements); } else { // Not quite a no-op; ensures volatile write semantics // 进入 else 说明要set的元素在数组中已经存在直接返回原数组 setArray(elements); } // 返回位置 index 处的老的元素 return oldValue; } finally { // 操作完成释放 lock 锁 lock.unlock(); } }2.5 remove 方法分析public E remove(int index) { final ReentrantLock lock this.lock; lock.lock(); try { Object[] elements getArray(); // 获取数组长度 int len elements.length; // 获取 index 处的元素 E oldValue get(elements, index); // 定义 numMoved 计算出要移动的元素的数量 int numMoved len - index - 1; // 如果 numMoved 为0说明要删除的元素恰好是数组的最后一个元素 if (numMoved 0) // 覆盖原来的数组 setArray(Arrays.copyOf(elements, len - 1)); else // numMoved 不为0则定义一个新数组长度为原来的数组长度-1 Object[] newElements new Object[len - 1]; // 将 0~index 处的元素复制到新数组中去 System.arraycopy(elements, 0, newElements, 0, index); // 将 index1~数组最后的元素移动到新数组中 System.arraycopy(elements, index 1, newElements, index, numMoved); // 覆盖原来的数组 setArray(newElements); } // 返回删除的元素值 return oldValue; } finally { // 操作完毕释放 lock 锁 lock.unlock(); } }三. 总结概括经过上面对 add 添加方法get 获取方法set 修改方法remove 删除方法的分析其实也可以看出相比于原来 ArrayList 集合的基础上添加了一把 lock 。在做增改删三种操作的时候搭配上 copy 复制数组的思想就可以做到线程安全这就是 CopyOnWriteArrayList 线程安全的核心设计思想不算特别难理解。
