CopyOnWriteArrayList简单认识

 

 

1、ArrayList非线程安全的缺陷

说到这个容器,从名字就可以看出,不得不说另外一个容器,也就是ArrayList。ArrayList是非线程安全的,也就是说在多个线程下进行读写,会出现异常。先举一个简单的例子,看看会出现什么问题

100个线程,每个线程都往集合里面添加1000个数据

 

public class T_CopyOnWriteList {

 

    public static void main(String[] args) {

        List<String> lists = new ArrayList<>(); //这个会出并发问题!

        Random r = new Random();

        Thread[] ths = new Thread[100];

 

        for (int i = 0; i < ths.length; i++) {

 

            Runnable task = new Runnable() {

                @Override

                public void run() {

                    for (int j = 0; j < 1000; j++) {

                        lists.add("a" + r.nextInt(10000));

                    }

                }

            };

            ths[i] = new Thread(task);

        }

 

        runAndComputeTime(ths);

        System.out.println(lists.size());

 

 

    }

 

    static void runAndComputeTime(Thread[] ths) {

        long s1 = System.currentTimeMillis();

        Arrays.asList(ths).forEach(t -> t.start());

        Arrays.asList(ths).forEach(t -> {

            try {

                t.join();

            } catch (InterruptedException e) {

                e.printStackTrace();

            }

        });

        long s2 = System.currentTimeMillis();

        System.out.println(s2 - s1);

    }

 

}

 

执行结果:报错了,正常应该是100*1000=100000

 

 

上面这个案例说明了ArrayList使用的局限性,既然是非线程安全,那我们就使用一些机制把它变安全不就好了。变安全的方法有很多。比如说替换成Vector,再或者是使用 Collections,可以将 ArrayList 包装成一个线程安全的类。不过这两种方法也有很大的缺点,那就是他们使用的都是独占锁,独占式锁在同一时刻只有一个线程能够获取,效率太低。于是CopyOnWriteArrayList 应用而生了。

 

修改:

 

public class T_CopyOnWriteList {

 

    public static void main(String[] args) {

        List<String> lists = new CopyOnWriteArrayList<>();

 

        Random r = new Random();

        Thread[] ths = new Thread[100];

 

        for (int i = 0; i < ths.length; i++) {

 

            Runnable task = new Runnable() {

                @Override

                public void run() {

                    for (int j = 0; j < 1000; j++) {

                        lists.add("a" + r.nextInt(10000));

                    }

                }

            };

            ths[i] = new Thread(task);

        }

 

        runAndComputeTime(ths);

        System.out.println("容量大小:"+lists.size());

 

 

    }

 

    static void runAndComputeTime(Thread[] ths) {

        long s1 = System.currentTimeMillis();

        Arrays.asList(ths).forEach(t -> t.start());

        Arrays.asList(ths).forEach(t -> {

            try {

                t.join();

            } catch (InterruptedException e) {

                e.printStackTrace();

            }

        });

        long s2 = System.currentTimeMillis();

        System.out.println(s2 - s1);

    }

 

 

}

 

 

CopyOnWriteArrayList 介绍

(1)独占锁效率低:采用读写分离思想解决

既然独占锁的效率低下,那我们可以换一种方式,采用读写分离式的思想将读操作和写操作进行分开即可。

读操作不加锁,所有线程都不会阻塞。写操作加锁,线程会阻塞。

 

2)写线程获取到锁,其他线程包括读线程阻塞

但是这时候又出现了另外一个问题了:写线程获取到锁之后,其他的读线程会陷入阻塞。

(3)复制思想:解决问题2

这咋办呢?我们可以再转化一下思想:

当我们往一个容器添加元素的时候,不直接往当前容器添加,而是先将当前容器进行 Copy,复制出一个新的容器,然后新的容器里添加元素,添加完元素之后,再将原容器的引用指向新的容器。

这时候会抛出来一个新的问题,也就是数据不一致的问题。如果写线程还没来得及写会内存,其他的线程就会读到了脏数据。

这就是CopyOnWriteArrayList 的思想和原理。就是拷贝一份写。所以使用条件也很局限,那就是在读多写少的情况下比较好。

  1. get方法

 

整个读的过程没有添加任何锁,就是普通的数组获取。

 

 

  1. add方法

 

写操作添加了一个锁ReentrantLock,这个锁我们可以决定在什么时候加锁和释放更加灵活。保证了写操作线程安全。能够体现Copy的思想代码是 Arrays.copyOf(elements, len + 1);也就是数组复制了一份,最后setArray回去。

 

这个容器很简单,虽然是采用了读写分离的思想,但是却有很大不同,不同之处在于copy。

 

1、读写锁

读线程具有实时性,写线程会阻塞。解决了数据不一致的问题。但是读写锁依然会出现读线程阻塞等待的情况

2、CopyOnWriteArrayList

读线程具有实时性,写线程会阻塞。不能解决数据不一致的问题。但是CopyOnWriteArrayList 不会出现读线程阻塞等待的情况

 

猜你喜欢

转载自blog.csdn.net/huzhiliayanghao/article/details/106790653