剖析fail-fast机制和ConcurrentModificationException

2024-02-06 03:32

本文主要是介绍剖析fail-fast机制和ConcurrentModificationException,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

快速失败,是java集合中的一种错误检测机制。当多个线程对集合进行结构上的改变操作时,就有可能会产生fail-fast机制。例如存在两个线程1和2,线程1通过Iterator在遍历集合中元素时,线程2修改了集合的结构(添加或者删除元素),这个时候就会抛出ConcurrentModificationException异常,从而产生了fail-fast机制。
并发修改异常ConcurrentModificationException:方法检测到对象的并发修改时,但是不允许这种修改,就会抛出该异常。单线程和多线程时都有可能产生这种异常。

分析ArrayList源码可知,迭代器在调用next() 和remove()方法时,都会调用checkForComodification()方法,该方法主要就是检测modCount和expectedModCount是否相等。如果不相等则抛出异常,从而产生了fail-fast机制。
modCount用来记录集合修改的次数,每修改一次(添加或者删除),modCount++。

具体分析如下:
线程1在遍历集合A。调用了集合的iterator方法。

public Iterator<E> iterator() {return new Itr();}

Itr是ArrayList的内部类,实现了Iterator接口

 private class Itr implements Iterator<E> {int cursor;      int lastRet = -1;        
int expectedModCount = modCount;………省略@SuppressWarnings("unchecked")public E next() {checkForComodification();………省略        
}public void remove() {if (lastRet < 0)throw new IllegalStateException();checkForComodification();………省略}@Override@SuppressWarnings("unchecked")public void forEachRemaining(Consumer<? super E> consumer) {………省略checkForComodification();}final void checkForComodification() {if (modCount != expectedModCount)throw new ConcurrentModificationException();}}

由上述可知,在调用remove和next方法时都会调用checkForComodification()方法。
看看checkForComodification()方法的实现,代码如下:

final void checkForComodification() {if (modCount != expectedModCount)throw new ConcurrentModificationException();}

这里进行了modCount 和expectedModCount的比较。如果不相等,则抛出ConcurrentModificationException异常。
下面分析一下什么时候才会不相等?

private class Itr implements Iterator<E> {int expectedModCount = modCount;

在新建itr对象时,会把当前的modCount的值传递给expectedModCount,之后, expectedModCount的值就不会再改变。因此下面要分析一下modCount什么时候会发生改变?以add方法为例

public void add(int index, E e) {rangeCheckForAdd(index);checkForComodification();parent.add(parentOffset + index, e);//修改modCount的值this.modCount = parent.modCount;this.size++;}

观察源码可知,add remove clear方法,只要涉及到修改集合结构时,就会改变modCount的值。
继续刚才线程1的执行,假设这时线程2执行了add方法,向集合中添加了一个元素,此时modCount++,线程1接着遍历,在执行到next函数时,调用checkForComodification方法比较expectedModCount和modCount的值,发现不相等了,就会抛出并发修改异常。从而产生了fail-fast机制。

如何解决fail-fast呢?或者解决并发修改异常呢?
可以使用同步来解决,在客户端调用会改变modCount值的方法时,加synchronized,或者直接使用Collections.synchronizedList类。
还可以使用jdk5提供的CopyOnWriteArrayList类。
CopyOnWriteArrayList仅仅实现了List集合接口,并没有继承AbstractList抽象类。ArrayList的iterator()方法是继承了AbstractList,但是CopyOnWriteArrayList是自己实现了iterator。最主要的原因是CopyOnWriteArrayList的Iterator实现类中没有checkForComodification方法,所以不会抛出并发修改异常。
那CopyOnWriteArrayList实现的原理是什么?以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();}
}

关键就在于

Object[] newElements = Arrays.copyOf(elements, len + 1);newElements[len] = e;setArray(newElements);

这三行代码。它是先对原先的数组进行复制,然后在复制之后的数组上进行添加元素,最后在改变原有数据的引用即可。怪不得该类叫做CopyOnWriteArrayList,无疑是先复制再进行写操作!

这篇关于剖析fail-fast机制和ConcurrentModificationException的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/683013

相关文章

Spring排序机制之接口与注解的使用方法

《Spring排序机制之接口与注解的使用方法》本文介绍了Spring中多种排序机制,包括Ordered接口、PriorityOrdered接口、@Order注解和@Priority注解,提供了详细示例... 目录一、Spring 排序的需求场景二、Spring 中的排序机制1、Ordered 接口2、Pri

MySQL 缓存机制与架构解析(最新推荐)

《MySQL缓存机制与架构解析(最新推荐)》本文详细介绍了MySQL的缓存机制和整体架构,包括一级缓存(InnoDBBufferPool)和二级缓存(QueryCache),文章还探讨了SQL... 目录一、mysql缓存机制概述二、MySQL整体架构三、SQL查询执行全流程四、MySQL 8.0为何移除查

一文详解Java Condition的await和signal等待通知机制

《一文详解JavaCondition的await和signal等待通知机制》这篇文章主要为大家详细介绍了JavaCondition的await和signal等待通知机制的相关知识,文中的示例代码讲... 目录1. Condition的核心方法2. 使用场景与优势3. 使用流程与规范基本模板生产者-消费者示例

一文带你理解Python中import机制与importlib的妙用

《一文带你理解Python中import机制与importlib的妙用》在Python编程的世界里,import语句是开发者最常用的工具之一,它就像一把钥匙,打开了通往各种功能和库的大门,下面就跟随小... 目录一、python import机制概述1.1 import语句的基本用法1.2 模块缓存机制1.

Redis主从/哨兵机制原理分析

《Redis主从/哨兵机制原理分析》本文介绍了Redis的主从复制和哨兵机制,主从复制实现了数据的热备份和负载均衡,而哨兵机制可以监控Redis集群,实现自动故障转移,哨兵机制通过监控、下线、选举和故... 目录一、主从复制1.1 什么是主从复制1.2 主从复制的作用1.3 主从复制原理1.3.1 全量复制

Redis缓存问题与缓存更新机制详解

《Redis缓存问题与缓存更新机制详解》本文主要介绍了缓存问题及其解决方案,包括缓存穿透、缓存击穿、缓存雪崩等问题的成因以及相应的预防和解决方法,同时,还详细探讨了缓存更新机制,包括不同情况下的缓存更... 目录一、缓存问题1.1 缓存穿透1.1.1 问题来源1.1.2 解决方案1.2 缓存击穿1.2.1

Java如何通过反射机制获取数据类对象的属性及方法

《Java如何通过反射机制获取数据类对象的属性及方法》文章介绍了如何使用Java反射机制获取类对象的所有属性及其对应的get、set方法,以及如何通过反射机制实现类对象的实例化,感兴趣的朋友跟随小编一... 目录一、通过反射机制获取类对象的所有属性以及相应的get、set方法1.遍历类对象的所有属性2.获取

MySQL中的锁和MVCC机制解读

《MySQL中的锁和MVCC机制解读》MySQL事务、锁和MVCC机制是确保数据库操作原子性、一致性和隔离性的关键,事务必须遵循ACID原则,锁的类型包括表级锁、行级锁和意向锁,MVCC通过非锁定读和... 目录mysql的锁和MVCC机制事务的概念与ACID特性锁的类型及其工作机制锁的粒度与性能影响多版本

Node.js 中 http 模块的深度剖析与实战应用小结

《Node.js中http模块的深度剖析与实战应用小结》本文详细介绍了Node.js中的http模块,从创建HTTP服务器、处理请求与响应,到获取请求参数,每个环节都通过代码示例进行解析,旨在帮... 目录Node.js 中 http 模块的深度剖析与实战应用一、引言二、创建 HTTP 服务器:基石搭建(一

Spring使用@Retryable实现自动重试机制

《Spring使用@Retryable实现自动重试机制》在微服务架构中,服务之间的调用可能会因为一些暂时性的错误而失败,例如网络波动、数据库连接超时或第三方服务不可用等,在本文中,我们将介绍如何在Sp... 目录引言1. 什么是 @Retryable?2. 如何在 Spring 中使用 @Retryable