你见过 ConcurrentHashMap 使用不当报错 java.lang.IllegalStateException: Recursive update 吗？

最新推荐文章于 2025-03-13 16:37:49 发布
最新推荐文章于 2025-03-13 16:37:49 发布
阅读量2k 收藏 1
点赞数 1
分类专栏： Java JDK 源码灌水 踩坑 文章标签： java 哈希 数据结构
版权声明：本文为博主原创文章，遵循 CC 4.0 BY-SA 版权协议，转载请附上原文出处链接和本声明。
本文链接：https://blog.csdn.net/wu_weijie/article/details/129289929
版权
本文探讨了在Java中遇到的`java.util.ConcurrentModificationException`异常，特别是在ShardingSphere项目中出现的`java.lang.IllegalStateException:Recursiveupdate`问题。文章详细介绍了问题背景，分析了`ConcurrentHashMap`的源码，指出递归更新导致的问题，并通过对比HashMap的行为解释了为何`ConcurrentModificationException`会出现。最后，文章提出了问题的修复策略，避免在使用`ConcurrentHashMap`的`computeIfAbsent`时发生递归调用。

摘要生成于 C知道 ，由 DeepSeek-R1 满血版支持， 前往体验 >

了解 Java 的同学，也许会见过一个异常 java.util.ConcurrentModificationException，这个一般在迭代器访问 Collection、Map 等数据结构过程中，修改了数据结构中的元素导致。
前段时间，ShardingSphere 遇到一个偶发报错的问题：java.lang.IllegalStateException: Recursive update。这个问题其实和并发修改问题有相似之处。本文主要记录该问题的排查与分析过程。

文章目录

问题背景

相关 issue java.lang.IllegalStateException: Recursive update caused by #24251

Apache ShardingSphere 在 Proxy 模块重构后的一段时间里，频繁发生偶发报错 java.lang.IllegalStateException: Recursive update。

引发该问题的重构 PR：https://github.com/apache/shardingsphere/pull/24251

java.util.ServiceConfigurationError: org.apache.shardingsphere.proxy.backend.mysql.handler.admin.MySQLSessionVariableHandler: Provider org.apache.shardingsphere.proxy.backend.mysql.handler.admin.MySQLDefaultSessionVariableHandler could not be instantiated

	at java.base/java.util.ServiceLoader.fail(ServiceLoader.java:586)
	at java.base/java.util.ServiceLoader$ProviderImpl.newInstance(ServiceLoader.java:813)
	at java.base/java.util.ServiceLoader$ProviderImpl.get(ServiceLoader.java:729)
	at java.base/java.util.ServiceLoader$3.next(ServiceLoader.java:1403)
	at org.apache.shardingsphere.infra.util.spi.ShardingSphereServiceLoader.load(ShardingSphereServiceLoader.java:56)
	at org.apache.shardingsphere.infra.util.spi.ShardingSphereServiceLoader.<init>(ShardingSphereServiceLoader.java:46)
	at java.base/java.util.concurrent.ConcurrentHashMap.computeIfAbsent(ConcurrentHashMap.java:1708)
	at org.apache.shardingsphere.infra.util.spi.ShardingSphereServiceLoader.getServiceInstances(ShardingSphereServiceLoader.java:73)
	at org.apache.shardingsphere.infra.util.spi.type.typed.TypedSPILoader.findService(TypedSPILoader.java:71)
	at org.apache.shardingsphere.infra.util.spi.type.typed.TypedSPILoader.getService(TypedSPILoader.java:126)
	at org.apache.shardingsphere.infra.util.spi.type.typed.TypedSPILoader.getService(TypedSPILoader.java:113)
	at org.apache.shardingsphere.proxy.backend.mysql.handler.admin.MySQLSetVariableAdminExecutor.lambda$execute$0(MySQLSetVariableAdminExecutor.java:56)
	at java.base/java.util.stream.Collectors.lambda$uniqKeysMapAccumulator$1(Collectors.java:180)
	at java.base/java.util.stream.ReduceOps$3ReducingSink.accept(ReduceOps.java:169)
	at java.base/java.util.HashMap$KeySpliterator.forEachRemaining(HashMap.java:1715)
	at java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:509)
	at java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:499)
	at java.base/java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:921)
	at java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
	at java.base/java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:682)
	at org.apache.shardingsphere.proxy.backend.mysql.handler.admin.MySQLSetVariableAdminExecutor.execute(MySQLSetVariableAdminExecutor.java:56)
	at org.apache.shardingsphere.proxy.backend.mysql.handler.admin.executor.MySQLSetVariableAdminExecutorTest.assertExecute(MySQLSetVariableAdminExecutorTest.java:66)
	at java.base/jdk.internal.reflect.DirectMethodHandleAccessor.invoke(DirectMethodHandleAccessor.java:104)
	at java.base/java.lang.reflect.Method.invoke(Method.java:578)
	at org.junit.platform.commons.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:727)
	... 省略 JUnit 调用栈
Caused by: java.lang.IllegalStateException: Recursive update
	at java.base/java.util.concurrent.ConcurrentHashMap.computeIfAbsent(ConcurrentHashMap.java:1763)
	at org.apache.shardingsphere.infra.util.spi.ShardingSphereServiceLoader.getServiceInstances(ShardingSphereServiceLoader.java:73)
	at org.apache.shardingsphere.infra.util.spi.type.typed.TypedSPILoader.findService(TypedSPILoader.java:71)
	at org.apache.shardingsphere.infra.util.spi.type.typed.TypedSPILoader.findService(TypedSPILoader.java:55)
	at org.apache.shardingsphere.proxy.backend.handler.admin.executor.DefaultSessionVariableHandler.<init>(DefaultSessionVariableHandler.java:36)
	at org.apache.shardingsphere.proxy.backend.mysql.handler.admin.MySQLDefaultSessionVariableHandler.<init>(MySQLDefaultSessionVariableHandler.java:28)
	at java.base/jdk.internal.reflect.DirectConstructorHandleAccessor.newInstance(DirectConstructorHandleAccessor.java:67)
	at java.base/java.lang.reflect.Constructor.newInstanceWithCaller(Constructor.java:500)
	at java.base/java.lang.reflect.Constructor.newInstance(Constructor.java:484)
	at java.base/java.util.ServiceLoader$ProviderImpl.newInstance(ServiceLoader.java:789)
	... 88 more

抛异常的是 ConcurrentHashMap 实例是以下的 LOADERS。

public final class ShardingSphereServiceLoader<T> {
    
    private static final Map<Class<?>, ShardingSphereServiceLoader<?>> LOADERS = new ConcurrentHashMap<>();
    
    private final Class<T> serviceInterface;

代码可见 ShardingSphere
https://github.com/apache/shardingsphere/blob/5.3.1/infra/util/src/main/java/org/apache/shardingsphere/infra/util/spi/ShardingSphereServiceLoader.java#L36

排查过程

阅读 ConcurrentHashMap Javadoc

ConcurrentHashMap 这么报错肯定有它的理由，先搜一下文档，发现确实存在关于该报错的说明。

Java 8

Java 8 的文档已经说明了，computeIfAbsent 的逻辑应该简短，且不许更新 map 内容。
https://docs.oracle.com/javase/8/docs/api/java/util/concurrent/ConcurrentHashMap.html#computeIfAbsent-K-java.util.function.Function-
在这里插入图片描述

Java 17

Java 17 的文档，把不许更新 map 内容的说明单独拎出来强调了。
https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/util/concurrent/ConcurrentHashMap.html#computeIfAbsent(K,java.util.function.Function)
在这里插入图片描述

ConcurrentHashMap 源码分析

本文使用的 JDK 为 Oracle OpenJDK 19.0.1。
搜索相关异常，发现 ConcurrentHashMap 有 9 处代码会抛出该异常。
在这里插入图片描述

其中，有 7 处代码判断的是，如果是节点是 ReservationNode 的实例，就抛出异常：

else if (f instanceof ReservationNode)
    throw new IllegalStateException("Recursive update");

以下是 ReservationNode 的定义，从 javadoc 可以看出这是 computeIfAbsent 和 compute 方法专用的占位符。

/**
 * A place-holder node used in computeIfAbsent and compute.
 */
static final class ReservationNode<K,V> extends Node<K,V> {
    ReservationNode() {
        super(RESERVED, null, null);
    }

    Node<K,V> find(int h, Object k) {
        return null;
    }
}

当 ConcurrentHashMap 的某个哈希桶上已经存在 ReservationNode，说明该实例的正在被调用 computeIfAbsent 方法。

那有没有可能这个调用是在多线程同时发生的？

当 key 映射到指定哈希桶上时，后续的写入逻辑会在该点位上以 synchronized 代码块执行，如果是不同线程调用 computeIfAbsent 方法，那么只有最先调用的线程能够执行写入逻辑，其他线程只能等待进入临界区。
所以，能够遇到 ReservationNode 的线程，肯定也是写入 ReservationNode 的线程。

另外 2 处代码大致意思是，如果 pred.next 不为空，则抛出异常：

Node<K,V> pred = e;
if ((e = e.next) == null) {
    if ((val = mappingFunction.apply(key)) != null) {
        if (pred.next != null)
            throw new IllegalStateException("Recursive update");
        added = true;
        pred.next = new Node<K,V>(h, key, val);
    }
    break;
}

其中 pred 和 e 其实是已经确定好当前 KV 准备写入的位置。如果 KV 计算出来后，发现要写入的位置不为空，说明在计算 Value 的过程中修改了当前哈希桶的内容。

与 ReservationNode 的情况相似，哈希桶写入是会加锁的，所以这个修改只可能在当前线程发生的。

初步结论 | 为什么是偶发而不是必现？

经过刚才的源码分析，可以判断：

  • 如果递归更新的 Key 没有哈希碰撞，写入位置在不同的哈希桶上，互不影响，则不会发生递归更新的问题；
  • 如果递归更新的 Key 存在哈希碰撞，写入位置在相同的哈希桶上，则抛出递归更新异常；

进一步思考

假如允许递归更新，会发生什么？

假设 Key1 与 Key2 存在哈希碰撞。

  1. 第一次调用 compute 方法，为 Key1 找好了写入位置，开始计算 Value；
  2. 结果计算 Value 的逻辑中，写入了 Key2，由于存在哈希碰撞，Key2 占用了第一步为 Key1 找好的写入位置；
  3. Key1 的 Value 计算好后，由于原本找好写入的位置已经被占用了，这时候怎么办？重新计算写入位置？

如果这种递归调用不仅两层，而是递归了很多层，compute 系列方法内部的逻辑可能会变得复杂且低效。

所以，直接禁止递归更新，也许是一种保持逻辑清晰、高效的方式。

换成 HashMap 会发生什么？

ConcurrentHashMap 不允许递归 compute 改变已有映射关系，那 HashMap 呢？

 public final class ShardingSphereServiceLoader<T> {
     
-    private static final Map<Class<?>, ShardingSphereServiceLoader<?>> LOADERS = new ConcurrentHashMap<>();
+    private static final Map<Class<?>, ShardingSphereServiceLoader<?>> LOADERS = new HashMap<>();
     
     private final Class<T> serviceInterface;

报错信息变成了标准的 java.util.ConcurrentModificationException

java.util.ConcurrentModificationException
	at java.base/java.util.HashMap.computeIfAbsent(HashMap.java:1229)
	at org.apache.shardingsphere.infra.util.spi.ShardingSphereServiceLoader.getServiceInstances(ShardingSphereServiceLoader.java:73)
	at org.apache.shardingsphere.infra.util.spi.type.typed.TypedSPILoader.findService(TypedSPILoader.java:71)
	at org.apache.shardingsphere.infra.util.spi.type.typed.TypedSPILoader.getService(TypedSPILoader.java:126)
	at org.apache.shardingsphere.infra.util.spi.type.typed.TypedSPILoader.getService(TypedSPILoader.java:113)
	at org.apache.shardingsphere.proxy.backend.mysql.handler.admin.MySQLSetVariableAdminExecutor.lambda$execute$0(MySQLSetVariableAdminExecutor.java:56)
	at java.base/java.util.stream.Collectors.lambda$uniqKeysMapAccumulator$1(Collectors.java:180)
	at java.base/java.util.stream.ReduceOps$3ReducingSink.accept(ReduceOps.java:169)
	at java.base/java.util.HashMap$KeySpliterator.forEachRemaining(HashMap.java:1715)
	at java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:509)
	at java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:499)
	at java.base/java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:921)
	at java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
	at java.base/java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:682)
	at org.apache.shardingsphere.proxy.backend.mysql.handler.admin.MySQLSetVariableAdminExecutor.execute(MySQLSetVariableAdminExecutor.java:56)
	at org.apache.shardingsphere.proxy.backend.mysql.handler.admin.executor.MySQLSetVariableAdminExecutorTest.assertExecute(MySQLSetVariableAdminExecutorTest.java:66)
	at java.base/jdk.internal.reflect.DirectMethodHandleAccessor.invoke(DirectMethodHandleAccessor.java:104)
	at java.base/java.lang.reflect.Method.invoke(Method.java:578)
	at org.junit.platform.commons.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:727)
	... 省略 JUnit 调用栈

所以，ConcurrentHashMap Recursive update 本质上和 ConcurrentModificationException 类似，只不过 ConcurrentHashMap 允许一定程度上（例如哈希不碰撞）的并发修改。

修复方式

避免 ConcurrentHashMap 的 computeIfAbsent 系列方法存在递归调用的情况。

ShardingSphere 修复案例：
Avoid ConcurrentHashMap Recursive update #24416

java.lang.IllegalStateException: Recursive entry to executePendingTransactio
Android、HTML、CSS、JS、JAVA、Kotlin、PHP等技术
08-26 1927
错误描述：ViewPager: Recursive entry to executePendingTransactions 错误产生： 在Fragment里面添加Viewpager，Viewpager由多个Fragment组成，在viewpager的setAdapter时产生错误 解决方法： public CustomFragmentPagerAdapter(android.sup
JDK15源码(二)：ConcurrentHashMap(插入元素、初始化、扩容、计数、树化)
liuffei的专栏
12-30 813
static class Segment<K,V> extends ReentrantLock implements Serializable { private static final long serialVersionUID = 2249069246763182397L; final float loadFactor; Segment(float lf) { this.loadFactor = lf; } }
【Android】java.lang.IllegalStateException: Recursive entry to executePendingTransactions
weixin_33739646的博客
05-21 152
  正文  错误 java.lang.IllegalStateException: Recursive entry to executePendingTransactions     at android.support.v4.app.FragmentManagerImpl.execPendingActions(FragmentManager.java:1416)     at android.s...
已解决：java.lang.IllegalStateException 异常的正确解决方法，亲测有效！！！
最新发布
蠢货日记
03-13 378
创建Springboot项目后，没有编辑代码，运行后发生如上报错；创建项目时把默认的url改成 阿里云镜像地址即可，如下博客操作。
ConcurrentHashMap的错误理解和纠正
qq_30761967的博客
08-25 1720
/** Implementation for put and putIfAbsent */ final V putVal(K key, V value, boolean onlyIfAbsent) { if (key == null || value == null) throw new NullPointerException(); int hash = spread(key.hashCode()); int binCount = 0; .
HashMap报错：java.util.ConcurrentModificationException
liwenxia626的专栏
03-23 3893
转自：https://blog.csdn.net/dyingfair/article/details/56481352 HashMap是线程不安全的 ，那么为什么说它是线程不安全的呢？ 首先来看一下官方API有关HashMap线程不安全的描述： Note that this implementation is not synchronized. If multiple threa...
Android学习指南 — Java知识点汇总，flutter整合百度地图sdk
m0_64319112的博客
11-19 390
分代收集算法 GC 分代的基本假设：绝大部分对象的生命周期都非常短暂，存活时间短。 “分代收集”（Generational Collection）算法，把Java堆分为新生代和老年代，这样就可以根据各个年代的特点采用最适当的收集算法。在新生代中，每次垃圾收集时都发现有大批对象死去，只有少量存活，那就选用复制算法，只需要付出少量存活对象的复制成本就可以完成收集。而老年代中因为对象存活率高、没有额外空间对它进行分配担保，就必须使用“标记-清理”或“标记-整理”算法来进行回收。 垃圾收集器 CMS收集器 .
Spark源码和调优简介 Spark Core
腾讯技术工程
01-16 1763
作者：calvinrzluo，腾讯 IEG 后台开发工程师本文基于 Spark 2.4.4 版本的源码，试图分析其 Core 模块的部分实现原理，其中如有错误，请指正。为了简化论述，将部...
解决Caused by: java.lang.IllegalStateException:
牛肉胡辣汤
11-02 1万+
通过调整JVM的-Xss参数、检查循环继承依赖项和更新相关库和依赖，我们可以解决​​Caused by: java.lang.IllegalStateException: 由于StackOverflower错误无法完成对web应用程序[/lib]的批注的扫描​​异常。在解决这个问题时，我们需要对应用程序的结构和依赖进行深入的分析和调试，以确定根本原因并采取相应的措施。当我们开发Web应用程序时，有时候会遇到上述的​​异常。
2024年Java常见面试题目，java集合框架面试
2401_84413490的博客
04-20 758
1.1 传统应用架构的问题1.2 微服务架构是什么1.3 微服务架构有哪些特点和挑战1.4 如何搭建微服务架构2.1 Spring Boot 是什么2.2 如何使用Spring Boot框架2.3 Spring Boot生产级特性3.1 Node.js 是什么3.2 如何使用 Node.js3.3 使用Node.js搭建微服务网关4.1 ZooKeeper 是什么4.2 如何使用 ZooKeeper4.3 实现服务注册组件4.4 实现服务发现组件5.1 Docker 是什么5.2 如何使用 Docker5.
dict-recursive-update:一个执行递归更新的Python模块处理2个字典
05-15
dict-递归更新 一个执行递归更新的Python模块处理2个字典。 用法 安装 pip install dict-recursive-update 例子 >> > from dict_recursive_update import recursive_update >> > recursive_update ({ 'a' : { 'b' : 2 }}, { 'a' : { 'b' : 3 , 'd' : 4 }, 'e' : 5 }) { 'a' : { 'b' : 3 , 'd' : 4 }, 'e' : 5 } >> > recursive_update ( 'a' , 'b' ) Traceback ( most recent call last ): ... TypeError : Params of recursive_update should be dicts
HashMap之快速失败
chewbee的专栏
10-23 2707
HashMap之快速失败为什么HashMap通过迭代器自身的remove或add方法就不会出现迭代器失败？HashMap所有集合类视图所返回迭代器都是快速失败（fast-fail）的。 在HashMap中，有一个变量modCount来指示集合被修改的次数。在创建Iterator迭代器的时候，会给这个变量赋值给expectedModCount。当集合方法修改集合元素时，例如集合的remove()方
java.lang.IllegalStateException: Recursive entry to executePendingTransactions
WheroJ的专栏
01-06 481
在Fragment里面添加Viewpager，Viewpager由多个Fragment组成 java.lang.IllegalStateException: Recursive entry to executePendingTransactions 找到发送错误的地方是viewpager.setAdapter()处。 我的应用场景是： 嵌套使用Fragment使用，最外层使用了一
HashMap 出现ConcurrentModificationException 异常
m0_63989537的博客
08-11 2369
快速了解hashmap的快速失败原理!
关于Caused by: java.lang.IllegalStateException:问题解决办法！
热门推荐
m0_52255061的博客
03-26 2万+
IDEA中出现Caused by: java.lang.IllegalStateException: ContainerBase.addChild: start: org.apache.catalina.LifecycleException: Failed to start component [StandardEngine[Catalina].StandardHost[localhost].StandardContext[/javaweb_01_cookie_war]]。。。的解决办法！ 今天新建的一个
并发下HashMap错误分析
蓝天白云
08-15 1033
目录 1.并发add相同hash值or相同key的元素，导致丢失 2. Rehash导致死循环 1.并发add相同hash值or相同key的元素，导致丢失 Jdk1.7源码 void addEntry(int hash, K key, V value, int bucketIndex) {     if ((size &gt;= threshold) &amp;&amp;...
HashMap之删除报错ConcurrentModificationException
上善若泪
02-06 815
集合由映射支持，如果在对集合进行迭代时修改了映射（通过迭代器自己的移除操作除外），则迭代的结果是未定义的。是表示期望的修改次数，在迭代器构造的时候这两个值是相等，如果在遍历过程中这两个值出现了不同步就会抛出。操作，如果这个操作时替换操作如上例中将第一个元素进行修改，就没有抛出异常，但是如果是使用。添加元素的操作，则肯定会抛出异常了。这里实际还是直接对集合进行的操作，而不是通过迭代器进行操作。代码编译成的字节码，从中揣测它到底是怎么实现的了。语法的一个增强，那么它的底层到底是怎么实现的呢？
java.lang.IllegalStateException: COMPLETED 解决方法
02-01
java.lang.IllegalStateException: COMPLETED 是Java中的一个异常类型，表示当前操作在已经完成的状态下被调用，这通常是由于程序逻辑错误或者不正确的调用顺序导致的。要解决这个问题，你可以考虑以下几个方面： 1. 检查代码逻辑：首先，你需要仔细检查代码逻辑，确保在调用相关方法之前，没有提前完成或结束相关操作。这可能涉及到对方法调用顺序、条件判断和循环等进行仔细检查。 2. 检查并发操作：如果你的代码涉及到多线程或并发操作，那么可能是由于线程间的竞争条件导致了该异常。你可以考虑使用同步机制（如锁、信号量等）来保证线程安全性，或者使用并发工具类（如Atomic类、ConcurrentHashMap等）来避免竞争条件。 3. 检查资源释放：有时候，该异常可能是由于资源没有正确释放导致的。比如，在使用IO流或数据库连接时，需要确保在使用完毕后及时关闭相关资源。你可以使用try-with-resources语句或者手动关闭资源来避免该异常。 4. 查看相关文档和日志：如果以上方法都没有解决问题，你可以查看相关的文档和日志，了解该异常的具体上下文和原因。这可能需要查看相关库或框架的官方文档，或者查看程序的日志文件，以便更好地理解和解决问题。 希望以上方法能够帮助你解决 java.lang.IllegalStateException: COMPLETED 异常。如果你有任何进一步的问题，请随时提问。
评论
添加红包

请填写红包祝福语或标题

个

红包个数最小为10个

元

红包金额最低5元

当前余额3.43元 前往充值 >
需支付：10.00元
成就一亿技术人!
领取后你会自动成为博主和红包主的粉丝 规则
hope_wisdom
发出的红包

打赏作者

wuweijie@apache.org

你的鼓励将是我创作的最大动力

¥1 ¥2 ¥4 ¥6 ¥10 ¥20
扫码支付：¥1
获取中
扫码支付

您的余额不足，请更换扫码支付或充值

打赏作者

实付元
使用余额支付
点击重新获取
扫码支付
钱包余额 0

抵扣说明：

1.余额是钱包充值的虚拟货币，按照1:1的比例进行支付金额的抵扣。
2.余额无法直接购买下载，可以购买VIP、付费专栏及课程。

余额充值