ConcurrentMap提供原子操作确保线程安全,其核心方法如putIfAbsent、computeIfAbsent和merge等可避免竞态条件。例如用computeIfAbsent实现缓存时,多个线程请求同一key仅会创建一次实例;使用merge统计词频可原子地更新数值。关键在于利用这些原子方法替代“检查再更新”的非原子组合操作,从而保证高并发下的正确性与效率。

在Java中,ConcurrentMap 是一个支持高并发访问的线程安全映射接口,位于 java.util.concurrent 包下。它继承自 Map 接口,并提供了一系列原子性操作方法,能够在多线程环境下安全地执行更新操作,而无需额外的同步控制。
理解 ConcurrentMap 的原子操作语义
ConcurrentMap 的核心优势在于其提供的某些方法具备原子性,这意味着在执行这些方法时,整个操作是不可中断的,不会出现中间状态被其他线程看到的情况。这在高并发场景中非常关键,能有效避免竞态条件。
常见的原子操作包括:
- putIfAbsent(K key, V value):若当前键没有映射值(或映射为 null),则插入新值,返回原值(null 表示成功插入)。
- remove(Object key, Object value):仅当键对应的值与给定值相等时,才移除该条目。
- replace(K key, V oldValue, V newValue):仅当键存在且当前值等于 oldValue 时,将其替换为 newValue。
-
computeIfAbsent(K key, Function
mappingFunction) :若键不存在,则使用函数计算值并原子地放入 map。 -
computeIfPresent(K key, BiFunction
remappingFunction) :若键存在且有非 null 值,则用函数重新计算并更新。 -
merge(K key, V value, BiFunction
remappingFunction) :将给定值合并到已有值中,若无值则直接放入。
使用 computeIfAbsent 实现线程安全的缓存
这是 ConcurrentMap 最典型的使用场景之一。假设我们要实现一个简单的对象缓存,确保每个 key 只创建一次实例。
立即学习“Java免费学习笔记(深入)”;
示例代码:
ConcurrentMapcache = new ConcurrentHashMap<>(); ExpensiveObject getInstance(String key) { return cache.computeIfAbsent(key, k -> new ExpensiveObject(k)); }
这里 computeIfAbsent 保证了即使多个线程同时请求同一个 key,也只会调用一次构造函数,其余线程会等待并获取已创建的实例。这比先 get 再判断再 put 安全得多。
利用 merge 进行原子计数或合并操作
在统计类场景中,比如词频统计、请求计数等,merge 方法非常高效。
示例:统计单词出现次数
ConcurrentMapwordCount = new ConcurrentHashMap<>(); void countWord(String word) { wordCount.merge(word, 1, Integer::sum); }
上述代码等价于:如果 word 不存在,放入 1;否则将旧值加 1。整个过程是原子的,不需要 synchronized 或显式锁。
避免常见误区:不要组合调用普通 Map 方法
尽管 ConcurrentMap 是线程安全的,但如果你将多个操作组合使用,比如:
// 错误示范
if (!map.containsKey(key)) {
map.put(key, value); // 非原子!可能多个线程同时通过判断
}
这种写法在并发下会导致重复写入。应改用 putIfAbsent 或 computeIfAbsent 来保证原子性。
基本上就这些。掌握 ConcurrentMap 提供的原子方法,能让你在编写并发程序时更简洁、更安全。关键是理解每个原子方法的语义,优先使用内置的高阶操作替代手动的“检查再更新”逻辑。










