剖析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

相关文章

JAVA线程的周期及调度机制详解

《JAVA线程的周期及调度机制详解》Java线程的生命周期包括NEW、RUNNABLE、BLOCKED、WAITING、TIMED_WAITING和TERMINATED,线程调度依赖操作系统,采用抢占... 目录Java线程的生命周期线程状态转换示例代码JAVA线程调度机制优先级设置示例注意事项JAVA线程

Java中自旋锁与CAS机制的深层关系与区别

《Java中自旋锁与CAS机制的深层关系与区别》CAS算法即比较并替换,是一种实现并发编程时常用到的算法,Java并发包中的很多类都使用了CAS算法,:本文主要介绍Java中自旋锁与CAS机制深层... 目录1. 引言2. 比较并交换 (Compare-and-Swap, CAS) 核心原理2.1 CAS

Spring Boot 集成 mybatis核心机制

《SpringBoot集成mybatis核心机制》这篇文章给大家介绍SpringBoot集成mybatis核心机制,本文结合实例代码给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值... 目录Spring Boot浅析1.依赖管理(Starter POMs)2.自动配置(AutoConfigu

Redis的安全机制详细介绍及配置方法

《Redis的安全机制详细介绍及配置方法》本文介绍Redis安全机制的配置方法,包括绑定IP地址、设置密码、保护模式、禁用危险命令、防火墙限制、TLS加密、客户端连接限制、最大内存使用和日志审计等,通... 目录1. 绑定 IP 地址2. 设置密码3. 保护模式4. 禁用危险命令5. 通过防火墙限制访问6.

JAVA实现Token自动续期机制的示例代码

《JAVA实现Token自动续期机制的示例代码》本文主要介绍了JAVA实现Token自动续期机制的示例代码,通过动态调整会话生命周期平衡安全性与用户体验,解决固定有效期Token带来的风险与不便,感兴... 目录1. 固定有效期Token的内在局限性2. 自动续期机制:兼顾安全与体验的解决方案3. 总结PS

详解Spring中REQUIRED事务的回滚机制详解

《详解Spring中REQUIRED事务的回滚机制详解》在Spring的事务管理中,REQUIRED是最常用也是默认的事务传播属性,本文就来详细的介绍一下Spring中REQUIRED事务的回滚机制,... 目录1. REQUIRED 的定义2. REQUIRED 下的回滚机制2.1 异常触发回滚2.2 回

深度剖析SpringBoot日志性能提升的原因与解决

《深度剖析SpringBoot日志性能提升的原因与解决》日志记录本该是辅助工具,却为何成了性能瓶颈,SpringBoot如何用代码彻底破解日志导致的高延迟问题,感兴趣的小伙伴可以跟随小编一起学习一下... 目录前言第一章:日志性能陷阱的底层原理1.1 日志级别的“双刃剑”效应1.2 同步日志的“吞吐量杀手”

基于Redis自动过期的流处理暂停机制

《基于Redis自动过期的流处理暂停机制》基于Redis自动过期的流处理暂停机制是一种高效、可靠且易于实现的解决方案,防止延时过大的数据影响实时处理自动恢复处理,以避免积压的数据影响实时性,下面就来详... 目录核心思路代码实现1. 初始化Redis连接和键前缀2. 接收数据时检查暂停状态3. 检测到延时过

Redis中哨兵机制和集群的区别及说明

《Redis中哨兵机制和集群的区别及说明》Redis哨兵通过主从复制实现高可用,适用于中小规模数据;集群采用分布式分片,支持动态扩展,适合大规模数据,哨兵管理简单但扩展性弱,集群性能更强但架构复杂,根... 目录一、架构设计与节点角色1. 哨兵机制(Sentinel)2. 集群(Cluster)二、数据分片

深入理解go中interface机制

《深入理解go中interface机制》本文主要介绍了深入理解go中interface机制,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学... 目录前言interface使用类型判断总结前言go的interface是一组method的集合,不