文档章节

CopyOnWriteArrayList详解

古月楼
 古月楼
发布于 2013/10/08 11:54
字数 867
阅读 7.9W
收藏 27

    CopyOnWriteArrayList是ArrayList 的一个线程安全的变体,其中所有可变操作(add、set等等)都是通过对底层数组进行一次新的复制来实现的。

     这一般需要很大的开销,但是当遍历操作的数量大大超过可变操作的数量时,这种方法可能比其他替代方法 有效。在不能或不想进行同步遍历,但又需要从并发线程中排除冲突时,它也很有用。“快照”风格的迭代器方法在创建迭代器时使用了对数组状态的引用。此数组在迭代器的生存期内不会更改,因此不可能发生冲突,并且迭代器保证不会抛出ConcurrentModificationException。创建迭代器以后,迭代器就不会反映列表的添加、移除或者更改。在迭代器上进行的元素更改操作(remove、set和add)不受支持。这些方法将抛出UnsupportedOperationException。允许使用所有元素,包括null。

    内存一致性效果:当存在其他并发 collection 时,将对象放入CopyOnWriteArrayList之前的线程中的操作 happen-before 随后通过另一线程从CopyOnWriteArrayList中访问或移除该元素的操作。 

   这种情况一般在多线程操作时,一个线程对list进行修改。一个线程对list进行fore时会出现java.util.ConcurrentModificationException错误。

   下面来看一个列子:两个线程一个线程fore一个线程修改list的值。

package com.lucky.concurrent.list;

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class CopyOnWriteArrayListDemo {
	/**
	 * 读线程
	 * @author wangjie
	 *
	 */
	private static class ReadTask implements Runnable {
		List<String> list;

		public ReadTask(List<String> list) {
			this.list = list;
		}

		public void run() {
			for (String str : list) {
				System.out.println(str);
			}
		}
	}
	/**
	 * 写线程
	 * @author wangjie
	 *
	 */
	private static class WriteTask implements Runnable {
		List<String> list;
		int index;

		public WriteTask(List<String> list, int index) {
			this.list = list;
			this.index = index;
		}

		public void run() {
			list.remove(index);
			list.add(index, "write_" + index);
		}
	}

	public void run() {
		final int NUM = 10;
		List<String> list = new ArrayList<String>();
		for (int i = 0; i < NUM; i++) {
			list.add("main_" + i);
		}
		ExecutorService executorService = Executors.newFixedThreadPool(NUM);
		for (int i = 0; i < NUM; i++) {
			executorService.execute(new ReadTask(list));
			executorService.execute(new WriteTask(list, i));
		}
		executorService.shutdown();
	}

	public static void main(String[] args) {
		new CopyOnWriteArrayListDemo().run();
	}
}
运行结果:


从结果中可以看出来。在多线程情况下报错。其原因就是多线程操作结果:那这个种方案不行我们就换个方案。用jdk自带的类CopyOnWriteArrayList来做容器。这个类和ArrayList最大的区别就是add(E) 的时候。容器会自动copy一份出来然后再尾部add(E)。看源码:

/**
     * Appends the specified element to the end of this list.
     *
     * @param e element to be appended to this list
     * @return <tt>true</tt> (as specified by {@link Collection#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();
	}
    }

用到了Arrays.copyOf 方法。这样导致每次操作的都不是同一个引用。也就不会出现java.util.ConcurrentModificationException错误。
换了种方案看代码:

//		List<String> list = new ArrayList<String>();
		CopyOnWriteArrayList<String> list = new CopyOnWriteArrayList<String>();
也就把容器list换成了 CopyOnWriteArrayList,其他的没变。线程里面的list不用改。因为 CopyOnWriteArrayList实现的也是list<E> 接口。看结果:

其结果没报错。
CopyOnWriteArrayList add(E
) 和remove(int index)都是对新的数组进行修改和新增。所以在多线程操作时不会出现java.util.ConcurrentModificationException错误。
所以最后得出结论:CopyOnWriteArrayList适合使用在读操作远远大于写操作的场景里,比如缓存。发生修改时候做copy,新老版本分离,保证读的高性能,适用于以读为主的情况。




© 著作权归作者所有

古月楼
粉丝 40
博文 41
码字总数 28071
作品 0
普陀
架构师
私信 提问
加载中

评论(7)

古月楼
古月楼 博主

引用来自“程序猿Zz”的评论

 请教楼主一个问题,CopyOnWriteArrayList这个类里面数组拷贝的方法Arrays.copyOf,只是复制了引用地址,数组内的对象还是和旧数组一样的啊,为什么旧能达到你在文中说的那个效果呢?

引用来自“601097836”的评论

数组是volatile
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的setArray()方法。就是把数组复制到新的数组上,并替换掉老的数据引用。0
601097836
601097836

引用来自“程序猿Zz”的评论

 请教楼主一个问题,CopyOnWriteArrayList这个类里面数组拷贝的方法Arrays.copyOf,只是复制了引用地址,数组内的对象还是和旧数组一样的啊,为什么旧能达到你在文中说的那个效果呢?
数组是volatile
程序猿Zz
 请教楼主一个问题,CopyOnWriteArrayList这个类里面数组拷贝的方法Arrays.copyOf,只是复制了引用地址,数组内的对象还是和旧数组一样的啊,为什么旧能达到你在文中说的那个效果呢?
古月楼
古月楼 博主

引用来自“宇林木风”的评论

LZ你好,add方法里的setArray()调用,是把老数组指向新数组么

引用来自“java我人生”的评论

是的/** * Sets the array. */ final void setArray(Object[] a) { array = a; }
java我人生
java我人生

引用来自“宇林木风”的评论

LZ你好,add方法里的setArray()调用,是把老数组指向新数组么
是的/** * Sets the array. */ final void setArray(Object[] a) { array = a; }
宇林木风
LZ你好,add方法里的setArray()调用,是把老数组指向新数组么
_Lara
_Lara
79
Spark2.1.0之源码分析——事件总线

版权声明:本文为博主原创文章,未经博主允许不得转载。 https://blog.csdn.net/beliefer/article/details/82344720 Spark定义了一个特质[1]ListenerBus,可以接收事件并且将事件提交到对应事...

泰山不老生
2018/09/03
0
0
Java集合---CopyOnWriteArrayList(5)

用途与特点 可用于多读取,写入需要线程安全的情况使用。 实现算法 该集合如其名字一样,是先创建一个新的数组,然后将旧的数组copy到新数组中,再切换数组引用。并且该数组是在每次添加时都...

兜兜毛毛
2018/12/04
21
0
Java基础——CopyOnWriteArrayList源码分析

版权声明:本文为博主原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。 https://blog.csdn.net/qq30379689/article/details/93546404 CopyOnWriteArrayList是什么 ...

Hensen_
2019/06/25
0
0
CopyOnWriteArrayList与Collections.synchronizedMap性能

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

MarkCo
2016/04/20
59
0
(转)线程安全的CopyOnWriteArrayList介绍

转载自:线程安全的CopyOnWriteArrayList介绍 证明CopyOnWriteArrayList是线程安全的 先写一段代码证明CopyOnWriteArrayList确实是线程安全的。 运行上面的代码,没有报出 java.util.Concurre...

晴天哥
2018/04/24
0
0

没有更多内容

加载失败,请刷新页面

加载更多

“>”(大于号)CSS选择器是什么意思?

例如: div > p.some_class { /* Some declarations */} >符号到底是什么意思? #1楼 html <div> <p class="some_class">lohrem text (it will be of red color )</p> <div> <p class="......

javail
23分钟前
47
0
mysql中int(11)的列大小是多少?

mysql中int(11)的列大小是多少? 以及可以在此列中存储的最大值? #1楼 mysql中int(11)的列大小是多少? (11) int数据类型的此属性与列的大小无关。 它只是整数数据类型的显示宽度。 从11....

技术盛宴
今天
40
0
聊聊artemis消息的推拉模式

序 本文主要研究一下artemis消息的推拉模式 拉模式 receive activemq-artemis-2.11.0/artemis-jms-client/src/main/java/org/apache/activemq/artemis/jms/client/ActiveMQMessageConsumer.......

go4it
今天
73
0
vue 全局前置守卫引起死循环的原因与解决方法

我们经常会用到全局前置守卫,如判断用户有没有登陆过,如果登陆过就直接跳到目的页面,如果没有登陆过,就跳转到登陆页。 先看官网对全局前置守卫的介绍 使用 router.beforeEach 注册一个全...

tianyawhl
今天
39
0
使用生成器模拟时间分片

对于cpu密集型任务, 时间分片可以有效减少页面卡顿, 不过对于纯计算型任务还是推荐使用worker在后台做计算 效果图, 计算密集型任务被分到每次只执行16ms, 每次执行完毕留给浏览器时间去响应事...

阿豪boy
今天
65
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部