文档章节

并发容器:CopyOnWriteArrayList

似是而非Sage
 似是而非Sage
发布于 2016/08/16 19:46
字数 732
阅读 27
收藏 0

0.ConpyOnWriteArrayList的使用场景

在多线程中,如果A线程在读取一个List时,B线程在向里面add数据,会抛出异常:java.util.ConcurrentModificationException

public class ErrorTest {

    public static void main(String[] args) throws InterruptedException {
        List<Integer> list = Arrays.asList(1, 2, 3, 4, 5);

        final ArrayList<Integer> list_thrd = new ArrayList<>(list);
        Thread thread = new Thread(new Runnable() {
            @Override
            public void run() {
                int count = 0;
                while (true) {
                    list_thrd.add(count++);
                }
            }
        });

        thread.setDaemon(true);
        thread.start();

        Thread.sleep(3);
        for (Integer integer : list_thrd) {
            System.out.println(integer);
        }
    }

}

运行这段代码,会抛出java.util.ConcurrentModificationException,即主线程在遍历list元素的时候,子线程在向里面添加元素。在这种情况下,我们可以使用CopyOnWriteArrayList进行操作。

1.初步了解CopyOnWriteArrayList

CopyOnWrite,字面意思就是写时复制。通俗的说,就是我们向容器中添加数据的时候,并不是向容器本身添加数据。而是,先copy一个副本,向里面添加记录,然后再将copy赋值给原对象。我们来看下面的代码

public class CopyOnWriteListTest {

    public static void main(String[] args) throws InterruptedException {
        List<Integer> temp = Arrays.asList(1, 2, 3, 4, 5);

        final CopyOnWriteArrayList<Integer> list = new CopyOnWriteArrayList<>(temp);

        Thread thread = new Thread(new Runnable() {
            @Override
            public void run() {
                int count = 0;
                while (true) {
                    list.add(count++);
                }
            }
        });

        thread.setDaemon(true);
        thread.start();

        Thread.sleep(3);
        for (Integer integer : list) {
            System.out.println(list.hashCode());
            System.out.println(integer);
        }
    }

}

我们在遍历CopyOnWriteArrayList集合的时候,同时打印出hashCode,可以看到输出结果:

-1813306013
1
1381289098
2
1109838168
3
-1094901371
4
-1008565321
5
-1813169375
0
-1540165649
1
-1441641759
2
1807730922
3
-870434537
4
-1185576945
5

这说明CopyOnWriteArrayList的add方法确实是创建了新的list对象,同时也不会抛出异常。

2.CopyOnWriteArrayList的实现原理

2.1 add方法

/** The lock protecting all mutators */
transient final ReentrantLock lock = new ReentrantLock();

/** The array, accessed only via getArray/setArray. */
private volatile transient Object[] array;
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();
        }
    }
  • 添加方法使用了重入锁来保证多线程添加的时候,不会生成多个list的副本在内存中;
  • array对象使用了volatile修饰,保证了多线程环境下的可见性
  • 最后使用setArray来给array对象赋值

2.2 get方法

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

get方法没有使用锁,所以读取的还是旧的数据,因为写入的时候并没有锁住旧的array对象

3.CopyOnWriteArrayList的使用场景 

从刚刚的例子中我们可以看出,CopyOnWriteArrayList适合读多写少的场景。例如黑白名单等,将数据初始化到List当中,当有较少写操作的时候,可以保证多并发情况下,List的最终一致性。但是,它也是有缺点的:当执行add操作的时候,由于要copy出一个对象,这时会导致内存占用加大。可能会造成频繁的Young GC和Full GC。

© 著作权归作者所有

共有 人打赏支持
似是而非Sage
粉丝 4
博文 11
码字总数 10369
作品 0
嘉定
后端工程师
并发容器之写时拷贝的 List 和 Set

对于一个对象来说,我们为了保证它的并发性,通常会选择使用声明式加锁方式交由我们的 Java 虚拟机来完成自动的加锁和释放锁的操作,例如我们的 synchronized。也会选择使用显式锁机制来主动...

Single_YAM
2017/12/02
0
0
CopyOnWriteArrayList源码剖析

1.1前言 CopyOnWriteArrayList是JAVA中的并发容器类,同时也是符合写时复制思想的CopyOnWrite容器。写时复制思想即是当我们往一个容器添加元素的时候,不直接往当前容器添加,而是先将当前容...

筱虾米
06/14
0
0
CopyOnWriteArrayList与Collections.synchronizedMap性能

平台: AMD X2 5400+,2G RAM,JDK6,eclipse 3.4 CopyOnWriteArrayList:专为多线程并发设计的容器,“写入时复制”策略。 Collections.synchronizedMap:同步容器,独占策略。 分析: 可以...

MarkCo
2016/04/20
35
0
Java多线程-并发容器

Java多线程-并发容器 在Java1.5之后,通过几个并发容器类来改进同步容器类,同步容器类是通过将容器的状态串行访问,从而实现它们的线程安全的,这样做会消弱了并发性,当多个线程并发的竞争...

tianfuguoss
2015/12/01
185
0
CopyOnWriteArraylist解析

自从JDK1.5引入引入concurrentHashmap,CopyOnWriteArraylist等并发集合后,java集合体系得到了很大的完善,我们有多了不少特殊情境的选择。 我们都知道,ArrayList存数数据的结构为数组,获...

令飞
2015/04/18
0
0

没有更多内容

加载失败,请刷新页面

加载更多

vue组件传值之(父子)

⚠️组件的作用域是孤立的,vue解决组件传值问题是通过props ⚠️子传父的时候需要vm.$emit触发实例上的事件,页面需要定一个方法去取值 ⚠️一定要注意命名方式和书写,例如mylChart和myl-c...

peakedness丶
8分钟前
0
0
SpringBoot开发案例之整合Dubbo分布式服务

前言 在 SpringBoot 很火热的时候,阿里巴巴的分布式框架 Dubbo 不知是处于什么考虑,在停更N年之后终于进行维护了。在之前的微服务中,使用的是当当维护的版本 Dubbox,整合方式也是使用的 ...

微笑向暖wx
22分钟前
0
0
TypeScript基础入门之装饰器(二)

转发 TypeScript基础入门之装饰器(二) 装饰器求值 如何应用装饰器应用于类内的各种声明的顺序: 1. 对每个实例成员应用参数装饰器,后跟Method,Accessor或Property Decorators。 2. 对每个静...

durban
23分钟前
0
0
Java程序员年薪40W是什么水平?税前还是税后?

很多人学Java都是冲着Java的高薪来的,那么搞Java的程序员,年薪40W到底是个什么水平呢,本文达妹和大家一起探讨一下。 前几天在论坛看到这么一个问题,搞Java的程序员年薪40w是什么水平?一...

架构师springboot
28分钟前
1
0
区块链100讲:盘点那些常用的加密算法原理

在开发过程中,常常用到各种加密方法和算法,本文总结了几种常用加密方法的原理。 1 对称加密 原理:加密和解密数据使用同一个密钥,适合对大量数据进行加解密 安全性:关键是密钥的保存方式...

HiBlock
42分钟前
0
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部