1. 程式人生 > 實用技巧 >CopyOnWriteArrayList原始碼閱讀筆記

CopyOnWriteArrayList原始碼閱讀筆記


簡介

ArrayList是開發中使用比較多的集合,它不是執行緒安全的,CopyOnWriteArrayList就是執行緒安全版本的ArrayList。CopyOnWriteArrayList同樣是通過陣列實現,這個類的名字叫“CopyOnWrite ”,它是在寫入的時候拷貝陣列,對副本進行操作。


原理

CopyOnWriteArrayList採用了一種讀寫分離的併發策略。CopyOnWriteArrayList容器允許併發讀,讀操作是無鎖的,效能較高。至於寫操作,比如向容器中新增一個元素,則首先將當前容器複製一份,然後在新副本上執行寫操作,結束之後再將原容器的引用指向新容器。示意圖如下:



繼承體系


通過類圖,可以看到CopyOnWriteArrayList的繼承體系·:

  • 實現了List, RandomAccess, Cloneable, java.io.Serializable等介面。

  • 實現了List,提供了基礎的新增、刪除、遍歷等操作。

  • 實現了RandomAccess,提供了隨機訪問的能力。

  • 實現了Cloneable,可以被克隆。

  • 實現了Serializable,可以被序列化。


原始碼分析

屬性

    //可重入鎖,保證執行緒安全
    final transient ReentrantLock lock = new ReentrantLock();
    
    //存放資料元素的陣列,只能通過get/set方法訪問
    private transient volatile Object[] array;

    final Object[] getArray() {
        return array;
    }
    
    final void setArray(Object[] a) {
        array = a;
    }
  • lock:用於修改時加鎖,使用transient修飾表示不自動序列化。
  • array:被使用volatile修飾表示一個執行緒對這個欄位的修改另外一個執行緒立即可見。

構造方法

  • 無參構造方法:建立一個空陣列
public CopyOnWriteArrayList() {
        setArray(new Object[0]);
 }
  • 有參構造方法,引數為集合
    public CopyOnWriteArrayList(Collection<? extends E> c) {
        Object[] elements;
         // 如果c也是CopyOnWriteArrayList型別
        // 那麼直接把它的陣列拿過來使用
        if (c.getClass() == CopyOnWriteArrayList.class)
            elements = ((CopyOnWriteArrayList<?>)c).getArray();
        else {
           //否則,先轉換為陣列
            elements = c.toArray();
            // c.toArray might (incorrectly) not return Object[] (see 6260652)
           //  檢查c.toArray()返回的是不是Object[]型別,如果不是,重新拷貝成Object[].class型別
            if (elements.getClass() != Object[].class)
                elements = Arrays.copyOf(elements, elements.length, Object[].class);
        }
        setArray(elements);
    }
  • 有參構造方法,引數為陣列
    //把toCopyIn的元素拷貝給當前list的陣列。
    public CopyOnWriteArrayList(E[] toCopyIn) {
        setArray(Arrays.copyOf(toCopyIn, toCopyIn.length, Object[].class));
    }

add(E e)

新增一個元素到末尾

    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();
        }
    }

add(int index, E element)

在指定位置插入陣列

 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;
            if (numMoved == 0)
            // 如果插入的位置是最後一位
            // 那麼拷貝一個n+1的陣列, 其前n個元素與舊陣列一致
                newElements = Arrays.copyOf(elements, len + 1);
            else {
                // 如果插入的位置不是最後一位
               // 那麼新建一個n+1的陣列
                newElements = new Object[len + 1];
                //拷貝舊陣列[0,……index-1]下標的元素
                System.arraycopy(elements, 0, newElements, 0, index);
                //拷貝舊陣列的其餘元素到新陣列[index+1,……length+1],剛好空出了index下標位置
                System.arraycopy(elements, index, newElements, index + 1,
                                 numMoved);
            }
            //將插入的元素放到index下標位置
            newElements[index] = element;
            //給array賦值
            setArray(newElements);
        } finally {
           //釋放鎖
            lock.unlock();
        }
    }

寫入操作:

  • 在上面新增元素的操作中,都進行了加鎖的操作
  • 拷貝一個新陣列,長度等於原陣列長度加1,並把原陣列元素拷貝到新陣列中
  • 把新陣列賦值給當前物件的array屬性,覆蓋原陣列

remove(int 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)
            // 如果移除的是最後一位
            // 那麼直接拷貝一份n-1的新陣列, 最後一位就自動刪除了
                setArray(Arrays.copyOf(elements, len - 1));
            else {
              // 如果移除的不是最後一位
             // 那麼新建一個n-1的新陣列
                Object[] newElements = new Object[len - 1];
                // 將前index個元素拷貝到新陣列中
                System.arraycopy(elements, 0, newElements, 0, index);
                // 將index後面(不包含)的元素往前挪一位
               // 這樣正好把index位置覆蓋掉了, 相當於刪除了
                System.arraycopy(elements, index + 1, newElements, index,
                                 numMoved);
                setArray(newElements);
            }
            return oldValue;
        } finally {
            //釋放鎖
            lock.unlock();
        }
    }

刪除操作:刪除操作同理,將除要刪除元素之外的其他元素拷貝到新副本中,然後切換引用,將原容器引用指向新副本。同屬寫操作,需要加鎖。


get(int index)

    public E get(int index) {
        return get(getArray(), index);
    }
   
    final Object[] getArray() {
        return array;
    }
    
    private E get(Object[] a, int index) {
        return (E) a[index];
    }

獲取操作:獲取操作屬於讀操作,直接通過陣列下標獲取資料元素,沒有加鎖,所以保證了效能。


size()

    public int size() {
       //返回陣列長度
        return getArray().length;
    }

和ArrayList不同,檢視ArrayList原始碼閱讀筆記,可以發現ArrayList中是有size屬性的,這是因為ArrayList陣列的長度實際是要大於集合的大小的。CopyOnWriteArrayList每次修改都是拷貝一份正好可以儲存目標個數元素的陣列,所以不需要size屬性,直接返回陣列長度即可。


總結

  • CopyOnWriteArrayList使用ReentrantLock重入鎖加鎖,保證執行緒安全;

  • CopyOnWriteArrayList的寫操作都要先拷貝一份新陣列,在新陣列中做修改,修改完了再用新陣列替換老陣列,所以空間複雜度是O(n),效能相對低下;

  • CopyOnWriteArrayList的讀操作支援隨機訪問,時間複雜度為O(1);

  • CopyOnWriteArrayList採用讀寫分離的思想,讀操作不加鎖,寫操作加鎖,且寫操作佔用較大記憶體空間,所以適用於讀多寫少的場合;

  • CopyOnWriteArrayList只保證最終一致性,不保證實時一致性;




紙上得來終覺淺,絕知此事要躬行。



參考:

【1】:【死磕 Java 集合】— CopyOnWriteArrayList原始碼分析
【2】:CopyOnWriteArrayList實現原理及原始碼分析