导读:本期聚焦于小伙伴创作的《Java并发编程中如何用双重检查锁配合ConcurrentHashMap实现线程安全的缓存穿透保护》,敬请观看详情。缓存穿透会让大量请求直接打到数据库,高并发下还可能引发线程安全问题。用双重检查锁配合ConcurrentHashMap能在保证线程安全的同时减少锁竞争。其核心思路是先从无锁的Map中读取,未命中再进入同步块二次校验,确认空值后写入特殊占位对象防止重复查库。相比全量加锁,这种方式把并发读的开销降到极低,也避免了synchronized放在方法上导致的吞吐瓶颈。实际落地时还要注意占位符清理与过期策略,否则会占用内存或返回陈旧数据。

在Java并发编程里,缓存穿透是指查询一个根本不存在的数据,导致请求绕过缓存直接访问数据库。当多个线程同时查询同一个不存在的键时,如果缓存层没有做并发控制,就会出现大量重复查库,甚至因为Map的并发写入产生数据不一致。使用双重检查锁配合ConcurrentHashMap,可以在高并发场景下用较低成本实现线程安全的防护,既防止重复查库,又保证Map操作不会出错。

Java并发编程中如何用双重检查锁配合ConcurrentHashMap实现线程安全的缓存穿透保护

双重检查锁的基础原理与实现结构

双重检查锁(Double-Checked Locking)的核心目标是减少同步范围。在缓存场景中,我们首先用ConcurrentHashMapget方法无锁读取,如果拿到结果就直接返回;如果为null,才进入synchronized块。进入同步块后再次调用get确认,这是因为在你等待锁的过程中,别的线程可能已经把值写进去了。第二次检查能避免重复执行加载逻辑,从而把锁竞争限制在“首次加载”这一瞬间。

很多初学者会把synchronized直接加在方法上,这在高并发下会让所有读请求串行化,吞吐量急剧下降。双重检查锁把同步只留给“未命中且确实要加载”的线程,绝大多数命中缓存的线程走的是无锁路径。下面是一段简化实现,展示如何用ConcurrentHashMapsynchronized配合完成基础防护:

public class SafeCache {
    private final ConcurrentHashMap<String, Object> map = new ConcurrentHashMap<>();
    private final Object NULL = new Object(); // 空值占位符

    public Object get(String key) {
        Object val = map.get(key);
        if (val != null) {
            return val == NULL ? null : val;
        }
        synchronized (this) {
            val = map.get(key);
            if (val != null) {
                return val == NULL ? null : val;
            }
            Object dbVal = queryFromDb(key); // 模拟查库
            if (dbVal == null) {
                map.put(key, NULL);
            } else {
                map.put(key, dbVal);
            }
            return dbVal;
        }
    }

    private Object queryFromDb(String key) {
        return null; // 实际中查数据库
    }
}

上面的代码里,NULL是一个特殊占位对象,用来标记“数据库里也没有”的键。这样下次再查同一个不存在的键时,第一次map.get就能拿到NULL,直接返回null,不会再进同步块。这个设计把“缓存穿透”转换成“缓存空对象”,是防护的关键一步。

ConcurrentHashMap为何适合该场景

ConcurrentHashMap在Java 8之后采用分段CAS加synchronized局部锁,读操作基本无锁。我们的双重检查锁依赖它提供的线程安全getput,但不依赖它做全局互斥。因为get本身线程安全,所以第一重检查不需要加锁;而put在同步块内执行,也由ConcurrentHashMap保证不会因并发写入而损坏结构。相比HashtableCollections.synchronizedMap,它不会让读操作也排队。

如果改用普通HashMap再加外部锁,那么在锁外做get就会有并发可见性问题,可能读到半个写操作的结果。而ConcurrentHashMap的happens-before规则保证了写后读可见。下表简单对比几种Map在缓存防护中的差异:

实现方式读性能写安全适用场景
HashMap+外部锁低(锁外读不安全)依赖锁不推荐
Hashtable低(方法级锁)内建遗留代码
ConcurrentHashMap+双重检查高(无锁读)内建高并发缓存

从表中可以看出,只有ConcurrentHashMap配合双重检查锁,才能做到读不加锁、写有保护。这也是为什么它在各类本地缓存组件里被广泛使用。需要注意的是,ConcurrentHashMap不保证复合操作的原子性,例如“不存在才放”如果用putIfAbsent也可以,但在我们这种需要查库并区分空占位的逻辑里,显式双重检查更直观可控。

空值占位与过期清理的工程细节

只写双重检查锁还不够,因为空值占位NULL会永久留在Map里。如果恶意构造大量不存在的键,内存会被占满。工程上通常给占位对象加时间戳,或者在另一个定时任务里清理超过一定时间的空条目。也可以在put时顺带记录写入时间,读取时发现过期就删除并放行查库。这样既挡住了瞬时穿透,也避免长期污染。

另一个细节是synchronized块的范围。如果queryFromDb很慢,锁会拖住其他也要加载的线程。可以改为用ConcurrentHashMapcomputeIfAbsent,它内部已经做了类似双重检查的机制,且锁粒度更细。但computeIfAbsent里不要做耗时IO,否则会阻塞该桶。示例改用computeIfAbsent的写法如下:

public Object getV2(String key) {
    Object val = map.get(key);
    if (val != null) {
        return val == NULL ? null : val;
    }
    // computeIfAbsent内部对key所在桶加锁,仅未存在时才执行
    Object result = map.computeIfAbsent(key, k -> {
        Object db = queryFromDb(k);
        return db == null ? NULL : db;
    });
    return result == NULL ? null : result;
}

这段代码把同步细节交给ConcurrentHashMap,可读性更好,但在JDK版本低于8时不可用。无论哪种写法,目标一致:让不存在的键只查一次库,并用线程安全容器承接结果。实际系统中还应结合Redis等分布式缓存做多层防护,本地Map主要解决单机高并发下的重复查库与线程安全,而不是替代远程缓存。

Java并发编程双重检查锁ConcurrentHashMap修改时间:2026-08-14 17:09:33

免责声明:​ 已尽一切努力确保本网站所含信息的准确性。网站内容多为原创整理与精心编撰,观点力求客观中立。本站旨在免费分享,内容仅供个人学习、研究或参考使用。若引用了第三方作品,版权归原作者所有。如内容涉及您的权益,请联系我们处理。
内容垂直聚焦
专注技术核心技术栏目,确保每篇文章深度聚焦于实用技能。从代码技巧到架构设计,为用户提供无干扰的纯技术知识沉淀,精准满足专业提升需求。
知识结构清晰
覆盖从开发到部署的全链路。AI、前端、编程、数据库、服务器、建站、系统层层递进,构建清晰学习路径,帮助用户系统化掌握开发与运维所需的核心技术。
深度技术解析
拒绝泛泛而谈,深入技术细节与实践难点。无论是数据库优化还是服务器配置,均结合真实场景与代码示例进行剖析,致力于提供可直接应用于工作的解决方案。
专业领域覆盖
精准对应开发生命周期。从前端界面到后端编程,从数据库操作到服务器运维,形成完整闭环,一站式满足全栈工程师和运维人员的技术需求。
即学即用高效
内容强调实操性,步骤清晰、代码完整。用户可根据教程直接复现和应用于自身项目,显著缩短从学习到实践的距离,快速解决开发中的具体问题。
持续更新保障
专注既定技术方向进行长期、稳定的内容输出。确保各栏目技术文章持续更新迭代,紧跟主流技术发展趋势,为用户提供经久不衰的学习价值。