快捷導(dǎo)航

Java集合中的CopyOnWriteArrayList使用詳解

更新時(shí)間：2023年12月19日 10:10:06 作者：會(huì)飛的豬zhu

這篇文章主要介紹了Java集合中的CopyOnWriteArrayList使用詳解,CopyOnWriteArrayList是ArrayList的線(xiàn)程安全版本,從他的名字可以推測(cè),CopyOnWriteArrayList是在有寫(xiě)操作的時(shí)候會(huì)copy一份數(shù)據(jù),然后寫(xiě)完再設(shè)置成新的數(shù)據(jù),需要的朋友可以參考下

前言

CopyOnWriteArrayList是ArrayList的線(xiàn)程安全版本，從他的名字可以推測(cè)。CopyOnWriteArrayList是在有寫(xiě)操作的時(shí)候會(huì)copy一份數(shù)據(jù)，然后寫(xiě)完再設(shè)置成新的數(shù)據(jù)。

CopyOnWriteArrayList

CopyOnWriteArrayList適用于讀多寫(xiě)少的并發(fā)場(chǎng)景。

上面的圖片展示你了CopyOnWriteArrayList的類(lèi)圖，可以看到它實(shí)現(xiàn)了List接口，如果去看ArrayList的類(lèi)圖的話(huà)，可以發(fā)現(xiàn)也是實(shí)現(xiàn)了List接口，也就得出一句廢話(huà)，ArrayList提供的api，CopyOnWriteArrayList也提供，下文中來(lái)分析CopyOnWriteArrayList是如何來(lái)做到線(xiàn)程安全的實(shí)現(xiàn)讀寫(xiě)數(shù)據(jù)的，而且也會(huì)順便對(duì)比ArrayList的等效實(shí)現(xiàn)為什么不支持線(xiàn)程安全的。

下面首先展示了CopyOnWriteArrayList中比較重要的成員：

     /** The lock protecting all mutators */
    final transient ReentrantLock lock = new ReentrantLock();
    /** The array, accessed only via getArray/setArray. */
    private transient volatile Object[] array;

可以看到，CopyOnWriteArrayList使用了ReentrantLock來(lái)支持并發(fā)操作，array就是實(shí)際存放數(shù)據(jù)的數(shù)組對(duì)象。ReentrantLock是一種支持重入的獨(dú)占鎖，任意時(shí)刻只允許一個(gè)線(xiàn)程獲得鎖，所以可以安全的并發(fā)去寫(xiě)數(shù)組，接下來(lái)看一下CopyOnWriteArrayList是如何使用這個(gè)lock來(lái)實(shí)現(xiàn)并發(fā)寫(xiě)的，下面首先展示了add方法的代碼：

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

當(dāng)我們往一個(gè)容器添加元素的時(shí)候，不直接往當(dāng)前容器添加，而是先將當(dāng)前容器進(jìn)行Copy，復(fù)制出一個(gè)新的容器，然后新的容器里添加元素，添加完元素之后，再將原容器的引用指向新的容器。

這樣做的好處是我們可以對(duì)CopyOnWrite容器進(jìn)行并發(fā)的讀，而不需要加鎖，因?yàn)楫?dāng)前容器不會(huì)添加任何元素。

所以CopyOnWrite容器也是一種讀寫(xiě)分離的思想，讀和寫(xiě)不同的容器。

他的缺點(diǎn)：

內(nèi)存占用問(wèn)題。因?yàn)镃opyOnWrite的寫(xiě)時(shí)復(fù)制機(jī)制，所以在進(jìn)行寫(xiě)操作的時(shí)候，內(nèi)存里會(huì)同時(shí)駐扎兩個(gè)對(duì)象的內(nèi)存，舊的對(duì)象和新寫(xiě)入的對(duì)象（注意:在復(fù)制的時(shí)候只是復(fù)制容器里的引用，只是在寫(xiě)的時(shí)候會(huì)創(chuàng)建新對(duì)象添加到新容器里，而舊容器的對(duì)象還在使用，所以有兩份對(duì)象內(nèi)存）。

如果這些對(duì)象占用的內(nèi)存比較大，比如說(shuō)200M左右，那么再寫(xiě)入100M數(shù)據(jù)進(jìn)去，內(nèi)存就會(huì)占用300M，那么這個(gè)時(shí)候很有可能造成頻繁的Yong GC和Full GC。

數(shù)據(jù)一致性問(wèn)題。CopyOnWrite容器只能保證數(shù)據(jù)的最終一致性，不能保證數(shù)據(jù)的實(shí)時(shí)一致性。

所以如果你希望寫(xiě)入的的數(shù)據(jù)，馬上能讀到，請(qǐng)不要使用CopyOnWrite容器?！井?dāng)執(zhí)行add或remove操作沒(méi)完成時(shí)，get獲取的仍然是舊數(shù)組的元素】

CopyOnWriteArrayList讀取時(shí)不加鎖，只是寫(xiě)入、刪除、修改時(shí)加鎖，所以一個(gè)線(xiàn)程X讀取的時(shí)候另一個(gè)線(xiàn)程Y可能執(zhí)行remove操作。

remove操作首先要獲取獨(dú)占鎖，然后進(jìn)行寫(xiě)時(shí)復(fù)制操作，就是復(fù)制一份當(dāng)前的array數(shù)組，然后在復(fù)制的新數(shù)組里面刪除線(xiàn)程X通過(guò)get訪(fǎng)問(wèn)的元素，比如：1。刪除完成后讓array指向這個(gè)新的數(shù)組。在線(xiàn)程x執(zhí)行g(shù)et操作的時(shí)候并不是直接通過(guò)全局array訪(fǎng)問(wèn)數(shù)組元素而是通過(guò)方法的形參a訪(fǎng)問(wèn)的，a指向的地址和array指向的地址在調(diào)用get方法的那一刻是一樣的，都指向了堆內(nèi)存的數(shù)組對(duì)象。之后改變array指向的地址并不影響get的訪(fǎng)問(wèn)，因?yàn)樵谡{(diào)用get方法的那一刻形參a指向的內(nèi)存地址就已經(jīng)確定了，不會(huì)改變。所以讀的仍然是舊數(shù)組。

對(duì)Arrays.copyOf的認(rèn)識(shí)

首先Arrays.copyOf(Object[] , length)，相對(duì)于數(shù)組來(lái)說(shuō)，是深拷貝，但是相對(duì)于數(shù)組元素來(lái)說(shuō)，只有數(shù)組為一維數(shù)組，并且元素為基本類(lèi)型、包裝類(lèi)、String類(lèi)為深拷貝，其他都為淺拷貝(針對(duì)的是數(shù)組元素)。

代碼實(shí)例：

public class Test{
   static  class Person{
        int age ;
        String name;
        public Person(int age, String name) {
            this.age = age;
            this.name = name;
        }
       @Override
       public String toString() {
           return "Person{" +
                   "age=" + age +
                   ", name='" + name + '\'' +
                   '}';
       }
   }
    public static void main(String[] args) {
       Person[] people = new Person[2];
       Person person1 = new Person(45,"dsad");
       Person person2 = new Person(105,"zhuzhu");
       people[0] = person1;
       people[1] = person2;
        Person[] people1 = Arrays.copyOf(people,people.length+1);
        System.out.println(Arrays.toString(people));
        System.out.println(Arrays.toString(people1));
      // 兩者誰(shuí)都可以改變，所以可以看出來(lái)，這個(gè)復(fù)制只是引用的復(fù)制，
     //而真正的對(duì)象其實(shí)還是同一個(gè)。
        people[0].age = 456;
        System.out.println("---------");
        System.out.println(Arrays.toString(people));
        System.out.println(Arrays.toString(people1));
    }
}

運(yùn)行結(jié)果：

這里其實(shí)并沒(méi)有把具體的對(duì)象復(fù)制，而是復(fù)制了對(duì)象的引用而已。如果我們使用的是int[] 類(lèi)型的數(shù)組，那么就會(huì)改變了。

代碼演示：

public class Test{
   static  class Person{
        int age ;
        String name;
        public Person(int age, String name) {
            this.age = age;
            this.name = name;
        }
       @Override
       public String toString() {
           return "Person{" +
                   "age=" + age +
                   ", name='" + name + '\'' +
                   '}';
       }
   }
    public static void main(String[] args) {
       int[] arr1 = {4,5,6};
        int[] ints = Arrays.copyOf(arr1, arr1.length);
        System.out.println(Arrays.toString(arr1));
        System.out.println(Arrays.toString(ints));
        System.out.println("--------------");
        arr1[0] = 12;
        System.out.println(Arrays.toString(arr1));
        System.out.println(Arrays.toString(ints));
    }
}

運(yùn)行結(jié)果：

可以直觀的看到，一個(gè)數(shù)組變換了，另一個(gè)沒(méi)有變換。

下面這個(gè)相當(dāng)于是一個(gè)set(index,val)源碼方法的一個(gè)易懂的方式：

public class Test{
   static  class Person{
        int age ;
        String name;
        public Person(int age, String name) {
            this.age = age;
            this.name = name;
        }
       @Override
       public String toString() {
           return "Person{" +
                   "age=" + age +
                   ", name='" + name + '\'' +
                   '}';
       }
   }
    public static void main(String[] args) {
       Person[] people = new Person[2];
       Person person1 = new Person(45,"dsad");
       Person person2 = new Person(105,"zhuzhu");
       people[0] = person1;
       people[1] = person2;
        Person[] people1 = Arrays.copyOf(people,people.length+1);
        System.out.println(Arrays.toString(people));
        System.out.println(Arrays.toString(people));
        people1[0] = new Person(45777,"456");
        System.out.println(Arrays.toString(people));
        System.out.println(Arrays.toString(people1));
        people = people1;
        System.out.println(Arrays.toString(people));
        System.out.println(Arrays.toString(people1));
    }
}

代碼結(jié)果：

到此這篇關(guān)于Java集合中的CopyOnWriteArrayList使用詳解的文章就介紹到這了,更多相關(guān)CopyOnWriteArrayList使用詳解內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: