美文网首页
JUC之并发List源码剖析

JUC之并发List源码剖析

作者: 薛定谔的猫_1406 | 来源:发表于2018-11-25 11:30 被阅读0次

    1.1 介绍

    并发包中的并发List只有CopyOnWriteArrayList,它是一个线程安全的ArrayList。对其进行的修改操作都是在其底层的一个复制数组(快照)上进行的,也就是使用了写时复制策略。


    CopyOnWriteArrayList类图
    • 每一个CopyOnWriteArrayList对象里有一个array数组对象用来存放具体的元素;
    • ReentrantLock独占锁对象用来保证同时只有一个线程对array进行修改

    5.2 主要方法源码解析

    5.2.1 添加元素

    内部有很多添加元素的方法
    以为add(E e)为例进行说明
     /**
         * Appends the specified element to the end of this list.
         *
         * @param e element to be appended to this list
         * @return {@code true} (as specified by {@link Collection#add})
         */
        public boolean add(E e) {
            //获取独占锁,如果多个线程都调用add方法则只有一个线程会获取到该锁
            final ReentrantLock lock = this.lock;
            lock.lock();
            try {
                Object[] elements = getArray();
                int len = elements.length;
    //复制array到新数组,添加元素到新数组(新数组的大小是原数组大小增加1,所以CopyOnWriteArrayList是无界锁)
                Object[] newElements = Arrays.copyOf(elements, len + 1);
                newElements[len] = e;
    //使用新数组替换添加元素前的数组
                setArray(newElements);
                return true;
            } finally {
    //释放独占锁
                lock.unlock();
            }
        }
    

    总结:
    在添加元素时首先复制了一个快照,然后再快照上进行添加,而不是直接在原来的数组上进行。

    5.2.2 获取元素

    get方法获取元素
    获取元素分为两步:
    1. 获取array数组;
    2. 通过index访问指定index位置处的元素。
      注意在上述过程中并没有加锁的步骤,这就导致了假如有x、y两个线程。x线程get元素,y线程remove元素。x线程在执行完步骤1后y线程获得执行权,此时y线程获取独占锁,然后删除了x要获取的index位置的元素,但是x线程内保存的数组依旧是原来的线程,发生了幻读。这就是写时复制策略产生的若一致性问题。

    5.2.3 修改指定元素

     /**
         * Replaces the element at the specified position in this list with the
         * specified element.
         *
         * @throws IndexOutOfBoundsException {@inheritDoc}
         */
        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();
            }
        }
    

    5.2.4 删除元素

     /**
         * Removes the element at the specified position in this list.
         * Shifts any subsequent elements to the left (subtracts one from their
         * indices).  Returns the element that was removed from the list.
         *
         * @throws IndexOutOfBoundsException {@inheritDoc}
         */
        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];
                    System.arraycopy(elements, 0, newElements, 0, index);
                    System.arraycopy(elements, index + 1, newElements, index,
                                     numMoved);
                    setArray(newElements);
                }
                return oldValue;
            } finally {
                lock.unlock();
            }
        }
    

    5.2.5 弱一致性的迭代器

    所谓的弱一致性指的是返回给迭代器后,其他线程对list的增删改对迭代器是不可见的。

    package beautyofparllel;
    
    import java.util.Iterator;
    import java.util.concurrent.CopyOnWriteArrayList;
    
    public class copyList {
        private static volatile CopyOnWriteArrayList<String> arrayList = new CopyOnWriteArrayList<String>();
    
        public static void main(final String[] args) throws InterruptedException {
            arrayList.add("hello");
            arrayList.add("alibaba");
            arrayList.add("welcome");
            arrayList.add("to");
            arrayList.add("hangzhou");
            Thread thread = new Thread(() -> {
               arrayList.set(1,"baba");
               arrayList.remove(2);
               arrayList.remove(3);
            });
            //保证在修改线程启动前获取迭代器
            Iterator<String> iterator = arrayList.iterator();
            thread.start();
            //等待子线程执行完毕
            thread.join();
            while (iterator.hasNext()){
                System.out.println(iterator.next());
            }
        }
    }
    
    
    并未获得增删改的结果,这就是弱一致性的体现

    相关文章

      网友评论

          本文标题:JUC之并发List源码剖析

          本文链接:https://www.haomeiwen.com/subject/zqxpqqtx.html