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 场景下的异常触发点
- 单线程遍历中修改集合
Kotlin的增强型for循环(for (item in list))底层依赖Java迭代器。若在遍历时直接调用集合的add/remove方法,会修改modCount,导致expectedModCount失效。 - 多线程并发修改
多个线程同时操作同一集合时,若一个线程在遍历,另一个线程修改集合,会引发异常。例如:
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)
}
}
- 隐式调用迭代器的场景
- 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 特性加持的优化方案
- 协程与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)
}
}
}
}
- 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),我们就像是进入了武侠世界的“少林武当”,这里高手云集,各种工具类和框架应有尽有,它们就像武...
- 一周热门
- 最近发表
- 标签列表
-
- curseforge官网网址 (16)
- 外键约束 oracle (36)
- oracle的row number (32)
- 唯一索引 oracle (34)
- oracle in 表变量 (28)
- oracle导出dmp导出 (28)
- oracle 数据导出导入 (16)
- oracle两个表 (20)
- 启动oracle的监听服务 (13)
- oracle 数据库 字符集 (20)
- powerdesigner oracle (13)
- oracle修改端口 (15)
- 左连接 oracle (15)
- oracle 转义字符 (14)
- oracle安装补丁 (19)
- matlab归一化 (16)
- matlab脚本 (14)
- matlab阶跃函数 (14)
- 三次样条插值matlab (14)
- 共轭梯度法matlab (16)
- matlab化简多项式 (20)
- 在线客服网页源码 (14)
- 多线程的创建方式 (29)
- 多线程 python (30)
- java多线程并发处理 (32)