You need to enable JavaScript to run this app.
优惠活动
大模型
产品
解决方案
定价
更多

Java高并发下如何安全更新共享资源映射且无性能损耗?

基于ConcurrentHashMap的原子化资源访问计数实现

方案一:利用ConcurrentHashMap的compute方法实现原子读改写

ConcurrentHashMap的compute方法会在目标键对应的桶锁保护下执行映射逻辑,天然保证整个“读取-修改-写入”流程的原子性,同时依托桶级锁机制,高并发场景下的吞吐量远优于全表锁的synchronizedMap。

重构后的代码:

public class ResourceTracker {
    private final ConcurrentHashMap<String, Integer> accessMap = new ConcurrentHashMap<>();

    public void registerAccess(String resourceId) {
        accessMap.compute(resourceId, (key, currentCount) -> 
            currentCount == null ? 1 : currentCount + 1
        );
    }
}

compute方法的核心逻辑:针对指定的resourceId,先获取当前计数(若不存在则为null),再根据逻辑计算新值并写入,整个过程在对应桶的锁范围内完成,完全避免竞态条件。


方案二:结合ConcurrentHashMap与AtomicInteger实现轻量级原子递增

当资源的重复访问频率远高于新增频率时,使用AtomicInteger存储计数可以进一步降低并发开销——AtomicInteger基于CAS(比较并交换)操作实现原子递增,无需每次修改都触发ConcurrentHashMap的桶锁逻辑。

重构后的代码(简化版):

public class ResourceTracker {
    private final ConcurrentHashMap<String, AtomicInteger> accessMap = new ConcurrentHashMap<>();

    public void registerAccess(String resourceId) {
        // computeIfAbsent原子性地初始化计数器(不存在时创建)
        accessMap.computeIfAbsent(resourceId, k -> new AtomicInteger(0))
                 .incrementAndGet();
    }
}

也可以手动处理初始化逻辑,便于理解底层行为:

public void registerAccess(String resourceId) {
    AtomicInteger counter = accessMap.get(resourceId);
    if (counter == null) {
        AtomicInteger newCounter = new AtomicInteger(1);
        // putIfAbsent确保只有第一个线程能成功初始化该键的计数器
        counter = accessMap.putIfAbsent(resourceId, newCounter);
        if (counter == null) {
            return;
        }
    }
    counter.incrementAndGet();
}

这种方案的优势:重复访问同一资源时,仅需执行CAS递增操作,锁的开销被大幅降低,高并发负载下性能更优。


方案选择建议

  • 若系统中资源新增频率较高,优先选择方案一,代码更简洁且无需额外维护原子对象;
  • 若资源的重复访问占比极高,方案二的CAS操作带来的性能收益更明显。

内容的提问来源于stack exchange,提问作者CELSO GABRIEL SARCEÑO CORADO

相关产品推荐
方舟 Agent Plan

超全模态模型 × Harness 升级,最新支持 Deepseek-V4.1-Flash、GLM-5.3 系列、Doubao-Seedream-5.0-pro、Kimi-K3 (部分), 限时 9.9 元起

最近更新时间:2026.06.02 07:24:51