百度360必应搜狗淘宝本站头条
当前位置:网站首页 > 技术资源 > 正文

ConcurrentModificationException 并发修改异常的真相与破解之道

moboyou 2025-06-08 18:49 3 浏览

在Kotlin开发中,
ConcurrentModificationException(并发修改异常)是让开发者头疼的“老熟人”。无论是单线程遍历时修改集合,还是多线程并发操作集合,这个异常都可能突然出现,打断程序的正常运行。本文将深入剖析该异常的根源,并结合Kotlin特性提供解决方案。

一、异常本质:modCount 与 expectedModCount 的博弈

在Java/Kotlin的集合框架中,ArrayList等非线程安全集合通过modCount(修改计数器)和expectedModCount(预期修改计数器)维护结构一致性。

  • modCount:记录集合的结构性修改次数(如add、remove)。
  • expectedModCount:迭代器创建时复制的modCount快照,用于校验迭代期间集合是否被修改。

当迭代器检测到modCount != expectedModCount时,会抛出
ConcurrentModificationException。例如:

val list = mutableListOf("A", "B", "C")
for (item in list) {  
    if (item == "B") {  
        list.remove("B") // 直接修改集合,触发异常  
    }  
}

二、Kotlin 场景下的异常触发点

  1. 单线程遍历中修改集合
    Kotlin的增强型for循环(for (item in list))底层依赖Java迭代器。若在遍历时直接调用集合的add/remove方法,会修改modCount,导致expectedModCount失效。
  2. 多线程并发修改
    多个线程同时操作同一集合时,若一个线程在遍历,另一个线程修改集合,会引发异常。例如:
val list = mutableListOf(1, 2, 3)
thread {  
    for (item in list) {  
        Thread.sleep(100) // 模拟耗时操作  
        println(item)  
    }  
}
thread {  
    repeat(3) {  
        list.add(it + 4)  
        Thread.sleep(50)  
    }  
}
  1. 隐式调用迭代器的场景
  • toString()方法(如ArrayList)可能隐式使用迭代器。
  • Kotlin的mapIndexed、filter等高阶函数若操作可变集合,也可能触发异常。

三、Kotlin 实战中的解决方案

1.使用迭代器的remove方法

Kotlin的迭代器支持remove操作,且会同步更新expectedModCount,避免异常:

val list = mutableListOf("A", "B", "C")
val iterator = list.iterator()
while (iterator.hasNext()) {  
    val item = iterator.next()  
    if (item == "B") {  
        iterator.remove() // 安全删除  
    }  
}
println(list) // 输出: [A, C]

2.使用CopyOnWriteArrayList

对于读多写少的场景,CopyOnWriteArrayList是最佳选择。它通过写时复制机制保证线程安全:

val list = java.util.concurrent.CopyOnWriteArrayList<String>()
list.addAll(listOf("A", "B", "C"))
for (item in list) {  
    if (item == "B") {  
        list.remove("B") // 不会抛出异常  
    }  
}
println(list) // 输出: [A, C]

3.显式同步控制

通过synchronized块或ReentrantLock显式加锁,确保同一时间只有一个线程操作集合:

val list = mutableListOf("A", "B", "C")
synchronized(list) {  
    for (item in list) {  
        if (item == "B") {  
            list.remove("B")  
        }  
    }  
}
println(list) // 输出: [A, C]

4.收集待操作元素后统一处理

先遍历集合收集需要修改的元素,再统一操作:

val list = mutableListOf("A", "B", "C")
val toRemove = mutableListOf<String>()
for (item in list) {  
    if (item == "B") {  
        toRemove.add(item)  
    }  
}
list.removeAll(toRemove)
println(list) // 输出: [A, C]

四、Kotlin 特性加持的优化方案

  1. 协程与withContext(Dispatchers.Default)
    在协程中,通过切换到Dispatchers.Default(共享线程池)并使用synchronized,可高效处理并发修改:
val list = mutableListOf(1, 2, 3)
val job = GlobalScope.launch {  
    withContext(Dispatchers.Default) {  
        synchronized(list) {  
            repeat(3) {  
                list.add(it + 4)  
                delay(50)  
            }  
        }  
    }  
}
  1. Sequence避免中间集合
    使用
    Sequence延迟计算,减少临时集合的创建:
val list = mutableListOf(1, 2, 3, 4, 5)
val result = list.asSequence()
    .filter { it % 2 == 0 }
    .map { it * 2 }
    .toList()
println(result) // 输出: [4, 8]

五、总结与最佳实践

  • 单线程场景:优先使用迭代器的remove方法,避免直接修改集合。
  • 多线程场景:读多写少:使用CopyOnWriteArrayList。写操作频繁:显式同步(synchronized/ReentrantLock)。
  • Kotlin 特性:结合协程、Sequence等特性,减少锁竞争和临时集合开销。


ConcurrentModificationException的本质是集合结构一致性的维护机制。通过理解modCount与expectedModCount的协作逻辑,结合Kotlin的迭代器、并发集合和协程特性,开发者可以轻松规避该异常,写出更健壮的代码。

相关推荐

Spring Boot3 中多线程技术的使用指南

在当今互联网应用场景下,高并发、大数据量处理已成为常态。用户对应用的响应速度和处理能力要求越来越高。以一个电商平台的订单处理系统为例,在促销活动期间,短时间内会涌入大量订单请求,如果采用单线程理,所有...

多线程会带来的一些问题

前言前面我们已经知道了,在使用多线程会给我们带来一些性能上的提升。但一个东西的出现总是会存在优缺点。1、多线程会在线程安全问题什么是线程安全?在深入理解JVM这本书中有句话可以很简单的去理解“如果一个...

经典面试题:SpringBoot 应用可以同时并发处理多少请求

前言hello,大家好,,最近逛帖子看到一个面试题:SpringBoot应用可以同时并发处理多少请求?看到这个问题大多数朋友也许都会回答200,这样你也许第二天就会收到如下拒信:你可能会很难疑惑,...

Java并发包(java.util.concurrent)探秘

Java并发包(java.util.concurrent)探秘在当今高并发、高负载的应用场景下,Java的并发包(java.util.concurrent)成为了开发者手中的神器。它不仅简化了并发编程...

操作系统-多线程编程-并发编程机制

十四、多线程编程POSIX标准中定义的现程,属性,操作方法被广泛认可和遵循。最贴近POSIX标准的线程实现,NPTL(NativePOSIXThreadsLibrary)线程可以看作进程的一个...

Java 多线程:让你的程序像开挂一样干活!

你有没有想过,当你的Java程序在处理大量任务时,能不能像哪吒三头六臂一样,同时做好几件事?答案就在Java多线程!它能让你的程序瞬间“开挂”,大大提高效率。别被“多线程”这个听起来高大...

记一次Synchronized使用不合理,导致的多线程下线程阻塞问题排查

在为客户进行性能诊断调优时,碰到了一个Synchronized关键字使用不合理导致多线程下线程阻塞的情况。用文字记录下了问题的整个发现-排查-分析-优化过程,排查过程中使用了我司商业化产品——XLan...

Disruptor—2.并发编程相关简介

大纲1.并发类容器2.volatile关键字与内存分析3.Atomic系列类与UnSafe类4.JUC常用工具类5.AQS各种锁与架构核心6.线程池的最佳使用指南1.并发类容器(1)Concurren...

实战项目:手把手带你实现一个高并发内存池

项目介绍1.这个项目做的是什么?当前项目是实现一个高并发的内存池,他的原型是google的一个开源项目tcmalloc,tcmalloc全称Thread-CachingMalloc,即线程缓存的ma...

JAVA多线程详解(超详细)

一、线程简介1、进程、线程程序:开发写的代码称之为程序。程序就是一堆代码,一组数据和指令集,是一个静态的概念。进程(Process):将程序运行起来,我们称之为进程。进程是执行程序的一次执行过程,它...

ConcurrentModificationException 并发修改异常的真相与破解之道

在Kotlin开发中,ConcurrentModificationException(并发修改异常)是让开发者头疼的“老熟人”。无论是单线程遍历时修改集合,还是多线程并发操作集合,这个异常都可能突然出...

Java并发编程核心技巧:让程序飞速奔跑的秘密武器

Java并发编程核心技巧:让程序飞速奔跑的秘密武器在这个信息化的时代,我们的应用程序需要处理越来越多的数据,同时还要保证响应速度和稳定性。Java作为一门广泛应用于企业级开发的语言,其强大的并发编程能...

如何使用CompletableFuture进行大数据量并发处理

面试官:有这样的一个需求,一批几百万的用户数据,需调用第三方的接口给用户发送消息。如何在一分钟内快速给这批用户发送完消息。在处理这种要求在一分钟内向大量用户发送消息的场景中,可以使用以下方法结合Com...

线程安全集合 --- Concurrent

引言最近看一些代码的时候,发现有人用System.Collections.Concurrent下的BlockingCollection很便利的实现了生产者-消费者模式,这是之前没有注意到的...

Java并发包(Concurrent)详解:让你的程序跑得更快更稳

Java并发包(Concurrent)详解:让你的程序跑得更快更稳提到Java并发包(Concurrent),我们就像是进入了武侠世界的“少林武当”,这里高手云集,各种工具类和框架应有尽有,它们就像武...