本文首发于一世流云专栏: https://segmentfault.com/blog...
CopyOnWriteArraySet
,是另外一类适合并发环境的SET工具类,也是在JDK1.5时,随着J.U.C包一块儿引入的。
咱们以前已经介绍过了ConcurrentSkipListSet,ConcurrentSkipListSet底层基于Skip List(跳表)实现,其操做平均时间复杂度均为O(logn)
。java
CopyOnWriteArraySet,从名字上能够看出,也是基于“写时复制”的思想。事实上,CopyOnWriteArraySet内部引用了一个CopyOnWriteArrayList
对象,以“组合”方式,委托CopyOnWriteArrayList对象实现了全部API功能。segmentfault
public class CopyOnWriteArraySet<E> extends AbstractSet<E> implements java.io.Serializable { private final CopyOnWriteArrayList<E> al; /** * Creates an empty set. */ public CopyOnWriteArraySet() { al = new CopyOnWriteArrayList<E>(); } public CopyOnWriteArraySet(Collection<? extends E> c) { if (c.getClass() == CopyOnWriteArraySet.class) { CopyOnWriteArraySet<E> cc = (CopyOnWriteArraySet<E>) c; al = new CopyOnWriteArrayList<E>(cc.al); } else { al = new CopyOnWriteArrayList<E>(); al.addAllAbsent(c); } } // ... }
咱们来看下CopyOnWriteArraySet是如何实现API接口的功能的:安全
public int size() { return al.size(); } public boolean isEmpty() { return al.isEmpty(); } public boolean contains(Object o) { return al.contains(o); } public Object[] toArray() { return al.toArray(); } public <T> T[] toArray(T[] a) { return al.toArray(a); } public void clear() { al.clear(); } public boolean remove(Object o) { return al.remove(o); } public boolean add(E e) { return al.addIfAbsent(e); } public boolean containsAll(Collection<?> c) { return al.containsAll(c); } public boolean addAll(Collection<? extends E> c) { return al.addAllAbsent(c) > 0; } public boolean removeAll(Collection<?> c) { return al.removeAll(c); } public boolean retainAll(Collection<?> c) { return al.retainAll(c); } public Iterator<E> iterator() { return al.iterator(); } public boolean removeIf(Predicate<? super E> filter) { return al.removeIf(filter); } public void forEach(Consumer<? super E> action) { al.forEach(action); }
能够看到,上述全部的方法都是经过委托实现的,惟一的区别就是CopyOnWriteArraySet不容许含有重复元素,因此添加元素(add
方法)时,内部调用了CopyOnWriteArrayList的addAllAbsent
方法。并发
既然CopyOnWriteArraySet也是基于“写时复制”的思想,那么它的特性也和CopyOnWriteArrayList是相似的,归结起来,有如下几点:工具
ConcurrentModificationException
,且迭代过程当中不支持修改操做。