为什么会有OnWriteArrayList?
们知道ArrayList和LinkedList实现的List都是非线程安全的,于是就有了Vector,它是基于ArrayList的线程安全集合,但Vector无论是add方法还是get方法都加上了synchronized修饰, 当多线程读写List必须排队执行,很显然这样效率比较是低下的,那有没有一种办法让效率提升,让当读List的时候线程是异步的,当写List是同步的呢?答案是OnWriteArrayList ,他是读写分离的,好处是提高线程访问效率,下面们对比下OnWriteArrayList和Vector执行效率。
import java.util.Vector;
import java.util.concurrent.OnWriteArrayList;
import java.util.concurrent.CountDownLatch;
/**
* @author :jiaolian
* @date :Created in 2021-01-18 15:28
* @description:安全list性能对比
* @modified By:
* 公众号:叫练
*/
public class SafeListTest {
private static Vector<String> safeList = new Vector<>();
//private static OnWriteArrayList<String> safeList = new OnWriteArrayList<>();
private static CountDownLatch countDownLatch = new CountDownLatch(2);
public static void main(String[] args) throws InterruptedException {
//初始化
safeList.add("叫练");
MySerive fishSerive = new MySerive();
long start = System.currentTimeMillis();
new Thread(()->{
fishSerive.read();
countDownLatch.countDown();
},"叫练读线程").start();
new Thread(()->{
fishSerive.write();
countDownLatch.countDown();
},"叫练写线程").start();
countDownLatch.await();
System.out.println("花费:"+(System.currentTimeMillis()-start));
}
private static class MySerive {
//读
public void read() {
for (int i=0 ;i<1000000; i++) {
safeList.get(0);
}
}
//写
public void write() {
for (int i=0 ;i<100000; i++) {
safeList.add("叫练");
}
}
}
}
如上代码:当安全集合用Vector时,执行时长是100毫秒,当安全集合用OnWriteArrayList时,执行时长是5000毫秒,神码?你不是说 OnWriteArrayList的效率要高么? 但执行情况OnWriteArrayList 执行的时长竟然是 Vector的50倍 !通过翻看源码,们发现当OnWriteArrayList写元素时是通过备份数组的方式实现的,当多线程同步激烈,数据量较大时会不停的复制数组,内存浪费严重。这就是时过长的原因!但是们还是认可读写分离思想!
什么是弱一致性
import java.util.Iterator;
import java.util.Vector;
import java.util.concurrent.OnWriteArrayList;
/**
* @author :jiaolian
* @date :Created in 2021-01-18 16:40
* @description:OnWriteArrayList弱一致性
* @modified By:
* 公众号:叫练
*/
public class WeekOnWriteArrayListTest {
private static OnWriteArrayList<String> safeList = new OnWriteArrayList<>();
//private static Vector<String> safeList = new Vector<>();
public static void main(String[] args) throws InterruptedException {
safeList.add("叫");
safeList.add("练");
Iterator<String> iterator = safeList.iterator();
Thread thread = new Thread(()->{
//删除下标为0的元素
safeList.remove(0);
});
thread.start();
//主线程等待thread执行完成;
thread.join();
while (iterator.hasNext()) {
System.out.println(iterator.next());
}
}
}
如上代码:主线程等待thread子线程执行完毕,循环打印safeList元素,最终执行结果如下图所示
你可能会有疑问,thread不是已经删除"叫"吗?控制台不是应该只打印一个"练"字吗?为什么还会打出"叫练"两个字,原因是main线程在执行Iterator
fail-safe特性
提到fail-safe,会先提到fail-fast,字面上翻译快速失败,它是集合 快速 检测失败机 制,防止集合不正确操作!一般情况下,如果线程通过iterator方式循环集合时,另外一个线程也修改了这个集合,们测试下,如上述测试弱一致性的代码,将private static OnWriteArrayList
如上图,java.util.ConcurrentModificationException,集合并发修改错误,但换成OnWriteArrayList执行正常,原因是OnWriteArrayList删除数据时会有集合快照。
所以他是fail-safe,而Vector是fail-fast!
总结
总结下吧,们用代码简述说明了OnWriteArrayList的读写分离,弱一致性,fail-safe,fail-safe等概念,并简述了实现原理。喜欢的请点赞加关注哦。是叫练【公众号】,边叫边练。
[] ) [](top
原文创作:叫练
原文链接:https://www.cnblogs.com/jiaolian/p/14294000.html
文章列表
- 高效读书,实用阅读指南
- 面试官:你说说ReentrantLock和Synchronized区别
- 线程池面试必考
- 正月十五吃汤圆CountDownLatch
- 核酸检测:让我明白AQS原理
- 最简单的JVM内存结构图
- 我们一起学程序-五子棋
- 并发队列:PriorityBlockingQueue和DelayQueue案例使用
- 并发队列:ArrayBlockingQueue实际运用场景和原理
- 图解定时任务线程池
- 图解CyclicBarrier运动员接力赛
- 叫练手把手教你读JVM之GC信息
- 原来我还有网络天赋
- ||运算你真的了解吗?
- join为啥会阻塞主线程?
- indexOf原理,Java,javascript,python实现
- Semaphore实战
- ReentrantReadWriteLock读写锁简单原理案例证明
- Lamda拉姆达表达式演化过程
- Java通过socket和DTU,RTU连接工业传感器通信
- Java单例7种测试实践
- CopyOnWriteArrayList 读写分离,弱一致性
- CMS前世今生
- 2020回顾,2021学习目标