Java中的fail-fast机制使用详解

 更新时间:2025年01月08日 14:53:10   作者:夜夜流光相皎洁_小宁  
fail-fast机制是Java集合中用于检测并发修改的一种机制,当一个线程遍历集合时,如果集合被其他线程修改,就会抛出ConcurrentModificationException异常,解决fail-fast机制的方法包括使用普通for循环、Iterator

Java的fail-fast机制使用

fail-fast 机制是Java集合(Collection)中的一种错误机制。当多个线程对同一个集合的内容进行操作时,就可能会产生fail-fast事件。

例如:

  • 当某一个线程 A 通过 iterator 去遍历某集合的过程中,若该集合的内容被其他线程所改变了,那么线程 A 访问集合时,就会抛出 ConcurrentModificationException 异常,产生 fail-fast 事件。
  • 这里的操作主要是指 add、remove 和 clear,对集合元素个数进行修改。

举例代码

单线程,在foreach循环里对某些集合元素进行元素的remove/add操作的时候,会触发fail-fast机制

public static void main(String[] args){
  List<String> strList = new ArrayList<>();
  strList.add("AA");
  strList.add("aa");
  strList.add("BB");
  strList.add("CC");
  for(String str : strList){
     if("aa".equals(str)){
       strList.remove(str);
     }
  }
}

多线程,在一个线程读时,另一个线程写入list,读线程会fail-fast

// 测试
public class TreadDemo1 {
   public static void main(String[] args){
        List<String> strList = new ArrayList<>();
        strList.add("AA");
        strList.add("aa");
        strList.add("BB");
        strList.add("CC");
        strList.add("DD");
        new MyThread1(strList).start();
        new MyThread2(strList).start();
   }
   static class Mythread1 extends Thread {
       private List<String> list;
       public Mythread1(List<String> list){
             this.list = list;
       }
       @Override
       public void run(){
             for(String str : list){
                 try{
                     Thread.sleep(100);
                 }catch(InterruptedException e){
                     e.printStackTrace();
                 }
                 System.out.println("MtThread1:"+str);
             }
       }
  }
  static class MyThread2 extends Thread {
       private list<String> list;
       public Mythread2(List<String> list){
             this.list = list;
       }
       @Override
       public void run(){
             for(int i = 0; i < list.size(); i++){
                 try{
                     Thread.sleep(100);
                 }catch(InterruptedException e){
                     e.printStackTrace();
                 }
                 if("aa".equals(list.get(i))){
                     list.remove(i);
                 }
             }
             System.out.println("MtThread2:"+list);
       }
  }
}

原理

将单线程编译后的.class反编译后发现,foreach其实是依赖while循环和Iterator实现的。

通过跟踪代码的异常堆栈,发现真正抛出异常的代码是:java.util.ArrayList$Itr.checkForComodification();该方法实在iterator.next()方法中调用的:

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

在该方法中modCount 和 expectedModCount进行了比较,如果二者不相等,则抛出ConcurrentModificationException 异常。

  • modCount是ArrayList中的一个成员变量。表示该集合实际被修改的次数。(操作集合类的remove()、add()、clear()方法会改变这个变量值)
  • expectedModCount是ArrayList 中的一个内部类---Itr(Iterator接口)中的成员变量。表示这个迭代器预期该集合被修改的次数。其值随着Itr被创建而初始化。只有通过迭代器对集合进行操作,该值才会改变。

所以,在使用Java的集合类的时候,如果发生ConcurrentModificationException 异常,优先考虑fail-fast有关的情况。

解决方式

1)使用普通for循环进行操作

普通for循环没有使用到Iterator的遍历,所以不会进行fail-fast的检验。

public static void main(String[] args){
        List<String> strList = new ArrayList<>();
        strList.add("AA");
        strList.add("aa");
        strList.add("BB");
        strList.add("CC");
        strList.add("DD");
        for(int i = 0; i < strList.size(); i++){
                 if("aa".equals(strList.get(i))){
                     strList.remove(i);
                 }
        }
   }

2)直接使用Iterator 进行操作

public static void main(String[] args){
        List<String> strList = new ArrayList<>();
        strList.add("AA");
        strList.add("aa");
        strList.add("BB");
        strList.add("CC");
        strList.add("DD");
        Iterator<String> iterator = strList.iterator();
        while(iterator.hasNext()){
             if("aa".equals(iterator.next())){
                iterator.remove();
             }
        }
   }

3)使用Java 8中提供的filter 过滤

Java 8 中可以把集合转换成流,对于流有一种filter操作,可以对原始Stream 进行某项过滤,通过过滤的元素被留下了生成一个新的Stream。

public static void main(String[] args){
        List<String> strList = new ArrayList<>();
        strList.add("AA");
        strList.add("aa");
        strList.add("BB");
        strList.add("CC");
        strList.add("DD");
        strList = strList.stream().filter(e -> !"aa".equals(e)).collect(Collectors.toList());
        System.out.println(strList);
   }

4)使用fail-safe的集合类

为了避免触发fail-fast机制导致异常,我们可以使用Java中提供的一些采用了fail-safe机制的集合类。

java.util.concurrent包下的容器都是fail-safe的,可以在多线程下并发使用,并发修改。同时也可以在foreach中进行add/remove等操作。

5)也可以使用foreach循环

如果我们非常确定一个集合中,某个即将删除的元素只包含一个的话,也是可以使用foreach循环的,只要删除之后,立即结束循环体,不在继续执行遍历就可以。

public static void main(String[] args){
  List<String> strList = new ArrayList<>();
  strList.add("AA");
  strList.add("aa");
  strList.add("BB");
  strList.add("CC");
  for(String str : strList){
     if("aa".equals(str)){
       strList.remove(str);
       break;
     }
  }
  System.out.println(strList);
}

总结

以上为个人经验,希望能给大家一个参考,也希望大家多多支持脚本之家。

相关文章

  • SpringBoot部署到外部Tomcat无法注册到Nacos服务端的解决思路

    SpringBoot部署到外部Tomcat无法注册到Nacos服务端的解决思路

    这篇文章主要介绍了SpringBoot部署到外部Tomcat无法注册到Nacos服务端,本文给大家分享完美解决思路,结合实例代码给大家讲解的非常详细,需要的朋友可以参考下
    2023-03-03
  • java打印国际象棋棋盘的方法

    java打印国际象棋棋盘的方法

    这篇文章主要为大家详细介绍了java打印出国际象棋棋盘的相关代码,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2019-05-05
  • 使用idea搭建一个spring mvc项目的图文教程

    使用idea搭建一个spring mvc项目的图文教程

    这篇文章主要介绍了使用idea直接创建一个spring mvc项目的图文教程,本文通过图文并茂的方式给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
    2020-03-03
  • 详解Java中格式化日期的DateFormat与SimpleDateFormat类

    详解Java中格式化日期的DateFormat与SimpleDateFormat类

    DateFormat其本身是一个抽象类,SimpleDateFormat 类是DateFormat类的子类,一般情况下来讲DateFormat类很少会直接使用,而都使用SimpleDateFormat类完成,下面我们具体来看一下两个类的用法:
    2016-05-05
  • Java中的移位运算符使用及原理详解

    Java中的移位运算符使用及原理详解

    在 Java 中,移位运算符用于对二进制数进行位移操作,它们可以将一个数的所有位向左或向右移动指定的位数,本文小编将给大家详细的介绍一下Java移位运算符,需要的朋友可以参考下
    2023-09-09
  • java中如何判断对象是否是垃圾

    java中如何判断对象是否是垃圾

    这篇文章主要介绍了java中如何判断对象是否是垃圾,Java有两种算法判断对象是否是垃圾:引用计数算法和可达性分析算法,需要的朋友可以参考下
    2023-04-04
  • Java判断闰年的2种方法示例

    Java判断闰年的2种方法示例

    这篇文章主要给大家介绍了关于Java判断闰年的2种方法,文中通过示例代码介绍的非常详细,对大家学习或者使用Java具有一定的参考学习价值,需要的朋友们下面来一起学习学习吧
    2019-09-09
  • 深入解析Jdk8中Stream流的使用让你脱离for循环

    深入解析Jdk8中Stream流的使用让你脱离for循环

    这篇文章主要介绍了Jdk8中Stream流的使用,让你脱离for循环,本文给大家介绍的非常详细,具有一定的参考借鉴价值,需要的朋友可以参考下
    2020-02-02
  • springboot+gradle 构建多模块项目的步骤

    springboot+gradle 构建多模块项目的步骤

    这篇文章主要介绍了springboot+gradle 构建多模块项目的步骤,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧
    2018-05-05
  • Java设计模式之职责链模式详解

    Java设计模式之职责链模式详解

    Java设计模式中有很多种类别,例如单例模式、装饰模式、观察者模式等。本文将为大家详细介绍其中的职责链模式,感兴趣的可以了解一下
    2021-12-12

最新评论