//在该集合上的写操作都是在原有的副本上进行的操作。这样可以在大量需要遍历的场景下提升性能。这也是一种读写分离思想的体现。
//先看构造函数
public CopyOnWriteArrayList() {
setArray(new Object[0]);
}
final void setArray(Object[] a) {
array = a;
}
public CopyOnWriteArrayList(Collection<? extends E> c) {
Object[] elements = c.toArray();
// c.toArray might (incorrectly) not return Object[] (see 6260652)
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));
}
//添加元素
public boolean add(E e) {
final ReentrantLock lock = this.lock;
lock.lock();
try {
Object[] elements = getArray();
int len = elements.length;
//复制一个新的数组
Object[] newElements = Arrays.copyOf(elements, len + 1);
newElements[len] = e;
setArray(newElements);
return true;
} finally {
lock.unlock();
}
}
final Object[] getArray() {
return array;
}
//在指定位置插入某个元素原有元素向后移
public void add(int index, E element) {
final ReentrantLock lock = this.lock;
lock.lock();
try {
Object[] elements = getArray();
int len = elements.length;
if (index > len || index < 0)
throw new IndexOutOfBoundsException("Index: "+index+
", Size: "+len);
Object[] newElements;
//需要向后移动的元素数量
int numMoved = len - index;
//在len的位置上插入
if (numMoved == 0)
newElements = Arrays.copyOf(elements, len + 1);
else {
newElements = new Object[len + 1];
//将elements数组从0开始的index个元素复制到newElements中。
System.arraycopy(elements, 0, newElements, 0, index);
从elements的index位置开始复制numMoved个元素到newElements中(从index+1位置开始)。
System.arraycopy(elements, index, newElements, index + 1,
numMoved);
}
//设置index位置的值为element。
newElements[index] = element;
setArray(newElements);
} finally {
lock.unlock();
}
}
//从集合中添加元素
public boolean addAll(Collection<? extends E> c) {
Object[] cs = c.toArray();
if (cs.length == 0)
return false;
final ReentrantLock lock = this.lock;
lock.lock();
try {
Object[] elements = getArray();
int len = elements.length;
//复制elemetns到newElements中。
Object[] newElements = Arrays.copyOf(elements, len + cs.length);
//复制cs到newElements(从len位置开始复制)中。
System.arraycopy(cs, 0, newElements, len, cs.length);
setArray(newElements);
return true;
} finally {
lock.unlock();
}
}
//从指定位置开始添加元素,原来位置的元素右移
public boolean addAll(int index, Collection<? extends E> c) {
Object[] cs = c.toArray();
final ReentrantLock lock = this.lock;
lock.lock();
try {
Object[] elements = getArray();
int len = elements.length;
if (index > len || index < 0)
throw new IndexOutOfBoundsException("Index: "+index+
", Size: "+len);
if (cs.length == 0)
return false;
int numMoved = len - index;
Object[] newElements;
//刚好在len位置上插入元素
if (numMoved == 0)
newElements = Arrays.copyOf(elements, len + cs.length);
else {
newElements = new Object[len + cs.length];
//从0位置开始复制index个元素到newElements。
System.arraycopy(elements, 0, newElements, 0, index);
//从index位置开始复制numMoved个元素到newElements(从index + cs.length位置开始,numMoved个元素)中。
System.arraycopy(elements, index,
newElements, index + cs.length,
numMoved);
}
//cs的0位置开始复制cs个元素到newElements(从index位置开始,cs.length个元素)中。
System.arraycopy(cs, 0, newElements, index, cs.length);
setArray(newElements);
return true;
} finally {
lock.unlock();
}
}
//如何元素不存在则添加元素
public boolean addIfAbsent(E e) {
final ReentrantLock lock = this.lock;
lock.lock();
try {
// Copy while checking if already present.
// This wins in the most common case where it is not present
Object[] elements = getArray();
int len = elements.length;
Object[] newElements = new Object[len + 1];
for (int i = 0; i < len; ++i) {
if (eq(e, elements[i]))
return false; // exit, throwing away copy
else
newElements[i] = elements[i];
}
newElements[len] = e;
setArray(newElements);
return true;
} finally {
lock.unlock();
}
}
private static boolean eq(Object o1, Object o2) {
return (o1 == null ? o2 == null : o1.equals(o2));
}
//将集合中不存在于数组中的元素进行插入。
public int addAllAbsent(Collection<? extends E> c) {
Object[] cs = c.toArray();
if (cs.length == 0)
return 0;
Object[] uniq = new Object[cs.length];
final ReentrantLock lock = this.lock;
lock.lock();
try {
Object[] elements = getArray();
int len = elements.length;
int added = 0;
//循环遍历有哪些元素不存在数值中将这些不存在数组中的元素封装到uniq中。
for (int i = 0; i < cs.length; ++i) { // scan for duplicates
Object e = cs[i];
//不在elements中并且不在uniq中。
if (indexOf(e, elements, 0, len) < 0 &&
//不在uniq中(防止c中有重复元素)
indexOf(e, uniq, 0, added) < 0)
uniq[added++] = e;
}
//有值需要插入
if (added > 0) {
Object[] newElements = Arrays.copyOf(elements, len + added);
System.arraycopy(uniq, 0, newElements, len, added);
setArray(newElements);
}
return added;
} finally {
lock.unlock();
}
}
private static int indexOf(Object o, Object[] elements,
int index, int fence) {
if (o == null) {
for (int i = index; i < fence; i++)
if (elements[i] == null)
return i;
} else {
for (int i = index; i < fence; i++)
if (o.equals(elements[i]))
return i;
}
return -1;
}
//在指定位置插入元素
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()?这主要是为了保证外部非volatile变量的happy-before语义。详见
//https://stackoverflow.com/questions/28772539/why-setarray-method-call-required-in-copyonwritearraylist
//一句简单的话来说就是volatile可以保证线程1看到的所有变量线程2也可以看到
setArray(elements);
}
return oldValue;
} finally {
lock.unlock();
}
}
private E get(Object[] a, int index) {
return (E) a[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)
setArray(Arrays.copyOf(elements, len - 1));
else {
Object[] newElements = new Object[len - 1];
//从0开始复制index个元素到newElements。
System.arraycopy(elements, 0, newElements, 0, index);
//再从index + 1位置复制numMoved个元素到newElements(从index位置开始接受)中。
System.arraycopy(elements, index + 1, newElements, index,
numMoved);
setArray(newElements);
}
return oldValue;
} finally {
lock.unlock();
}
}
//删除指定元素
public boolean remove(Object o) {
final ReentrantLock lock = this.lock;
lock.lock();
try {
Object[] elements = getArray();
int len = elements.length;
if (len != 0) {
// Copy while searching for element to remove
// This wins in the normal case of element being present
int newlen = len - 1;
Object[] newElements = new Object[newlen];
for (int i = 0; i < newlen; ++i) {
//找到了
if (eq(o, elements[i])) {
// found one; copy remaining and exit
//从i位置开始复制
for (int k = i + 1; k < len; ++k)
newElements[k-1] = elements[k];
setArray(newElements);
return true;
} else
//没有找到直接复制过去
newElements[i] = elements[i];
}
//如果删除的元素位于数组尾部
// special handling for last cell
if (eq(o, elements[newlen])) {
setArray(newElements);
return true;
}
}
return false;
} finally {
lock.unlock();
}
}
//从数组中移除包含在c中的元素
public boolean removeAll(Collection<?> c){
final ReentrantLock lock = this.lock;
lock.lock();
try {
Object[] elements = getArray();
int len = elements.length;
if (len != 0) {
// temp array holds those elements we know we want to keep
int newlen = 0;
//这里面保存最后剩下的元素
Object[] temp = new Object[len];
for (int i = 0; i < len; ++i) {
Object element = elements[i];
//如果c中不包含当前元素
if (!c.contains(element))
temp[newlen++] = element;
}
//如果长度不相等说明有元素被移除了
if (newlen != len) {
setArray(Arrays.copyOf(temp, newlen));
return true;
}
}
return false;
} finally {
lock.unlock();
}
}
//只保存存在collection中的元素
public boolean retainAll(Collection<?> c) {
final ReentrantLock lock = this.lock;
lock.lock();
try {
Object[] elements = getArray();
int len = elements.length;
if (len != 0) {
// temp array holds those elements we know we want to keep
int newlen = 0;
Object[] temp = new Object[len];
for (int i = 0; i < len; ++i) {
Object element = elements[i];
if (c.contains(element))
temp[newlen++] = element;
}
if (newlen != len) {
setArray(Arrays.copyOf(temp, newlen));
return true;
}
}
return false;
} finally {
lock.unlock();
}
}
//从列表中移除所有元素
public void clear() {
final ReentrantLock lock = this.lock;
lock.lock();
try {
setArray(new Object[0]);
} finally {
lock.unlock();
}
}
//是否包含某个元素
public boolean contains(Object o) {
Object[] elements = getArray();
return indexOf(o, elements, 0, elements.length) >= 0;
}
//是否包含指定集合的所有元素
public boolean containsAll(Collection<?> c) {
Object[] elements = getArray();
int len = elements.length;
for (Object e : c) {
if (indexOf(e, elements, 0, len) < 0)
return false;
}
return true;
}
//返回该元素第一次出现的索引
public int indexOf(Object o) {
Object[] elements = getArray();
return indexOf(o, elements, 0, elements.length);
}
//从指定位置开始搜索该元素第一次出现的索引
public int indexOf(E e, int index) {
Object[] elements = getArray();
return indexOf(e, elements, index, elements.length);
}
//从尾部开始搜索
public int lastIndexOf(Object o) {
Object[] elements = getArray();
return lastIndexOf(o, elements, elements.length - 1);
}
//返回最后一次出现在列表中的索引
public int lastIndexOf(E e, int index) {
Object[] elements = getArray();
return lastIndexOf(e, elements, index);
}
private static int lastIndexOf(Object o, Object[] elements, int index) {
if (o == null) {
for (int i = index; i >= 0; i--)
if (elements[i] == null)
return i;
} else {
for (int i = index; i >= 0; i--)
if (o.equals(elements[i]))
return i;
}
return -1;
}
public int size() {
return getArray().length;
}
public boolean isEmpty() {
return size() == 0;
}
//转化为Object类型的数组
public Object[] toArray() {
Object[] elements = getArray();
return Arrays.copyOf(elements, elements.length);
}
//转化为特定类型的数组
public <T> T[] toArray(T a[]) {
Object[] elements = getArray();
int len = elements.length;
if (a.length < len)
return (T[]) Arrays.copyOf(elements, len, a.getClass());
else {
System.arraycopy(elements, 0, a, 0, len);
if (a.length > len)
a[len] = null;
return a;
}
}
//判断是否相等这个实现有些疑惑为什么不先判断长度?再比较元素?先判断长度效率应该更高
public boolean equals(Object o) {
if (o == this)
return true;
if (!(o instanceof List))
return false;
List<?> list = (List<?>)(o);
Iterator<?> it = list.iterator();
Object[] elements = getArray();
int len = elements.length;
for (int i = 0; i < len; ++i)
//如果o的长度小于了队列的长度或者他们的元素不相等返回false
if (!it.hasNext() || !eq(elements[i], it.next()))
return false;
//o的长度大于了队列的长度
if (it.hasNext())
return false;
return true;
}
public int hashCode() {
int hashCode = 1;
Object[] elements = getArray();
int len = elements.length;
for (int i = 0; i < len; ++i) {
Object obj = elements[i];
hashCode = 31*hashCode + (obj==null ? 0 : obj.hashCode());
}
return hashCode;
}
//复制
public Object clone() {
try {
CopyOnWriteArrayList c = (CopyOnWriteArrayList)(super.clone());
c.resetLock();
return c;
} catch (CloneNotSupportedException e) {
// this shouldn't happen, since we are Cloneable
throw new InternalError();
}
}
public String toString() {
return Arrays.toString(getArray());
}
分享到:
相关推荐
Java并发容器CopyOnWriteArrayList实现原理及源码分析 Java并发容器CopyOnWriteArrayList是Java并发包中提供的一个并发容器,实现了线程安全且读操作无锁的ArrayList,写操作则通过创建底层数组的新副本来实现。...
5. **效率**:CopyOnWriteArrayList在大部分情况下非常适合读多写少的并发场景。当写操作频繁时,由于频繁复制数组,可能会导致性能下降,此时应考虑其他数据结构,如ConcurrentHashMap。 向CopyOnWriteArrayList...
CopyOnWriteArrayList是Java集合框架中的一个重要类,它是ArrayList的线程安全版本,特别适合于读多写少的并发场景。这个类通过一种称为“写时复制”(Copy-On-Write)的技术实现了读写分离,确保了在进行写操作时不会...
这些源码文件是人类可读的,其中包含了各种类、方法和逻辑,用于构建复杂的软件系统。Java源码遵循特定的语法规则,这些规则定义了如何组织代码、声明变量、控制流程、实现函数等。 1. **Java语法基础** - **...
- **应用场景**:适合于读多写少的场景,特别是那些需要频繁地读取数据而很少修改数据的应用程序。例如,缓存系统、日志记录、监控统计等。 #### 六、源码分析 - **类的继承关系**:`CopyOnWriteArrayList`继承自`...
- **线程安全**:由于基于CopyOnWriteArrayList,CopyOnWriteArraySet在并发环境下的读操作是无锁的,而写操作会创建一个新的底层数组,因此确保了线程安全。 - **不可重复**:由于Set接口的要求,...
- **CopyOnWriteArrayList和CopyOnWriteArraySet**:在迭代时不会抛出`ConcurrentModificationException`,适用于读多写少的场景。 - **Atomic*类**:如AtomicInteger、AtomicLong等,提供原子操作的包装类。 5. ...
《CopyOnWriteArrayList与CopyOnWriteArraySet源码解析》 CopyOnWriteArrayList与CopyOnWriteArraySet是Java集合框架中的两种线程安全的数据结构,它们在多线程环境下提供了高效且安全的操作。这两个类源自于`java....
再者,CopyOnWriteArrayList是一种特殊的线程安全列表,它通过复制原列表来保证并发安全,适用于读多写少的场景,提供了高效的迭代性能。 同步工具类如Semaphore(信号量)、CyclicBarrier(回环栅栏)和...
- **CopyOnWriteArrayList/CopyOnWriteArraySet**:适用于读多写少的情况,读操作无需加锁,写操作则复制整个集合。 7. **源码分析** - PDF文档和源码结合可以帮助读者深入理解多线程设计模式的实际应用,通过...
- **CopyOnWriteArrayList/CopyOnWriteArraySet**:写时复制策略,读操作无锁,写操作复制整个数组,适合读多写少的场景。 5. **线程池**: - **ExecutorService**:Java并发框架的一部分,提供线程池服务,可以...
- `CopyOnWriteArrayList`和`CopyOnWriteArraySet`: 在迭代时提供不变性,适合于读多写少的场景。 - `BlockingQueue`: 阻塞队列,提供线程安全的队列操作,常用于生产者消费者模式。 5. **原子变量** - `...
5. **原子操作类**:`java.util.concurrent.atomic`包提供了各种原子变量类,如`AtomicInteger`,`AtomicLong`等,它们支持原子性的读/修改/写操作,无需同步也能保证数据一致性。 6. **Future和CompletableFuture*...
- 分析`ArtConcurrentBook`源码中关于并发集合的实现,可以深入了解`ConcurrentHashMap`的分段锁策略,`CopyOnWriteArrayList`的写时复制策略等。 6. **线程池** - `ExecutorService`是线程池的接口,`...
- **CopyOnWriteArrayList/CopyOnWriteArraySet**:线程安全的动态数组,适用于读多写少的场景。 6. **原子类**: - `Atomic*`系列类如`AtomicInteger`、`AtomicLong`,提供原子操作,无需同步也能保证线程安全。...
- 由于CopyOnWriteArraySet的线程安全性,它适用于多线程环境,特别是读多写少的场景。 - 遍历速度快,因为迭代器基于集合的固定视图,不会因其他线程的修改而抛出异常。 - 修改操作代价高,不适合频繁修改的场景,...
java biginteger 源码 MultiThreadMode Single Thread Execution模式 使用synchronized方法或代码块,只能保证某一段代码是只能由一个线程执行。...CopyOnWriteArrayList线程安全的类,适用于读操作频繁的场景。 Gua
这种方式保证了读操作的高性能,但写操作相对较慢,适用于读多写少的场景。 3. **BlockingQueue**:阻塞队列是一种特殊类型的线程安全队列,它支持阻塞的插入(put)和移除(take)操作。常见的实现有...