HashMap用法是否线程安全？mapperdao库线程安全异常排查求助

阿华AIGC实验室

2026-5-26

解决MapperDAO线程安全问题：聚焦可变HashMap的隐患

嘿，我一眼就注意到你代码里的classCache用了scala.collection.mutable.HashMap——这个可变集合本身完全不是线程安全的，这大概率就是你遇到随机异常的根源！当多个线程同时对它做读写操作时，很容易触发竞态条件，导致数据错乱、丢值甚至抛出奇怪的并发异常。

问题拆解

你的proxyFor方法如果在多线程环境下被调用（比如Web应用的请求线程、异步任务线程），多个线程同时读写这个无保护的HashMap，就会破坏内部的数据结构——HashMap的扩容、哈希冲突处理都不是线程安全的，一旦并发操作就会出问题。

可行的解决方案

这里给你几个递进的解决思路：

替换为线程安全的并发集合（首选）
Scala标准库提供了scala.collection.concurrent.TrieMap，Java的java.util.concurrent.ConcurrentHashMap也是绝佳选择，二者都是为并发场景设计的，不需要额外的同步代码就能安全处理多线程读写。
替换示例：
```
private val classCache = new scala.collection.concurrent.TrieMap[CacheKey, (Class[_], Map[String, ColumnInfoRelationshipBase[_, Any, Any, Any]])]
```
TrieMap在高并发下的性能表现很不错，而且是Scala原生的API，用法和HashMap基本一致。
给原有HashMap添加同步保护
如果你不想更换集合，可以用Scala的SynchronizedMap特质包装原HashMap，或者用synchronized块包裹所有对classCache的读写操作：
包装示例：
```
private val classCache = new scala.collection.mutable.HashMap[CacheKey, (Class[_], Map[String, ColumnInfoRelationshipBase[_, Any, Any, Any]])] with scala.collection.mutable.SynchronizedMap[CacheKey, (Class[_], Map[String, ColumnInfoRelationshipBase[_, Any, Any, Any]])]
```
不过要注意，SynchronizedMap用的是全局锁，高并发场景下可能会有性能瓶颈，不如并发集合高效。
额外检查：CacheKey的正确性
顺便提一句，确保你的CacheKey（(Class[_], LazyLoad)）的equals和hashCode方法是正确实现的——如果键的哈希计算有问题，也可能导致缓存命中异常，不过这和线程安全是两个独立的问题，先解决并发集合的问题再排查这个。