讲师中心 微信公众号
AI工具推荐 视频效率加速

如何实现一个简单的阻塞锁_基于CAS与LockSupport的实战模拟

夏杰姑娘_9078

夏杰姑娘_9078

发布时间:2026-02-26 15:58:03

|

919人浏览过

|

来源于php中文网

原创

直接用Unsafe.compareAndSwapInt易卡死,因其不阻塞且失败后盲目自旋会吃满CPU;必须配合LockSupport.park/unpark实现阻塞等待,并用CAS设置等待标记以防唤醒丢失。

如何实现一个简单的阻塞锁_基于cas与locksupport的实战模拟

为什么直接用 Unsafe.compareAndSwapInt 容易卡死

因为 CAS 本身不阻塞,失败后若盲目重试(比如写个 while(true)),会疯狂自旋,吃满 CPU,而且根本没让出线程调度权。更麻烦的是,如果临界区操作稍长,其他线程在等待时完全无法被唤醒——你得自己搭“等-唤”机制,不能只靠 CAS。

实操建议:

  • 必须配合 LockSupport.park() 实现真正阻塞,而不是空转
  • CAS 只用来争抢锁状态(如用一个 int 字段表示 0=无锁,1=已锁),不是用来做业务逻辑同步的
  • 每次 park 前要确保当前线程是合法等待者,否则可能 park 了却没人 unpark,永久挂起
  • 注意 Unsafe 的字段偏移量必须用 objectFieldOffset 动态获取,硬编码值在不同 JVM 上会错

怎么用 LockSupport 避免丢失唤醒

常见错误是先 park 再检查状态,结果刚 park 就有线程 unlock 并 unpark,但此时还没注册等待,unpark 生效但无效果(unpark 是“发一次票”,park 是“兑一次票”,票不能攒)。

实操建议:

  • 必须在 park 前用 CAS 设置等待标记(比如把当前线程存入 waiters 链表头),再检查是否该 park
  • unlock 时要遍历等待队列,对每个线程调用 LockSupport.unpark(t),不能只 unpark 第一个
  • 避免在 park 后直接 while(true) 重试 CAS,应结合 Thread.interrupted() 检查中断,及时退出
  • LockSupport.park() 返回后不保证锁已被获取,仍需重新 CAS 尝试,这是标准的“check-then-act”模式

为什么不能用 volatile int state 替代 CAS 字段

volatile 只保证可见性和禁止重排序,不保证原子性。比如 state++ 是读-改-写三步,在多线程下必然丢更新;即使写成 state = 1,也无法区分“我设的”和“别人设的”,导致 unlock 时误释放。

实操建议:

  • 锁的获取/释放必须是原子的“比较并设置”,只能靠 Unsafe.compareAndSwapInt 或 AtomicInteger.compareAndSet
  • 如果不用 Unsafe,可用 AtomicInteger 模拟,但要注意其 getAndIncrement 等方法不适用于锁语义,必须用 compareAndSet(0, 1) 这类判断式写法
  • 别试图用 synchronized 包裹 CAS 操作来“保险”——那等于套娃,既失去轻量优势,又可能引发死锁

实际写一个最小可运行的自旋+阻塞混合锁

核心逻辑就三块:尝试 CAS 获取、失败后 park、unlock 时 unpark 头节点。下面这个版本去掉异常处理和公平性,仅保留最简骨架,能跑通但不推荐直接上线。

public class SimpleLock {
    private volatile Thread owner;
    private final AtomicInteger state = new AtomicInteger(0);
    private final AtomicReference<Thread> head = new AtomicReference<>();

    public void lock() {
        Thread me = Thread.currentThread();
        if (state.compareAndSet(0, 1)) {
            owner = me;
            return;
        }
        // 入队
        Thread old;
        do {
            old = head.get();
            Thread currentHead = head.compareAndSet(old, me) ? old : null;
        } while (currentHead == null);
        // 自旋 + park
        while (!state.compareAndSet(0, 1)) {
            if (Thread.interrupted()) throw new RuntimeException("Interrupted");
            LockSupport.park();
        }
        owner = me;
        head.set(null); // 清头
    }

    public void unlock() {
        if (Thread.currentThread() != owner) return;
        state.set(0);
        Thread h = head.get();
        if (h != null) LockSupport.unpark(h);
    }
}

关键点在于:head 是等待队列的简易实现,但真实场景中要用 Unsafe 操作链表节点,且必须用 UNSAFE.putOrderedObject 控制写顺序;另外,上面代码没处理多个等待者竞争 unpark,实际中需要循环 unpark 所有排队线程或改用 CLH 风格。

最易被忽略的是:park/unpark 的配对不是严格一对一,一个 unpark 可以抵消之前或之后的一次 park,所以状态检查和 park 必须在同一个内存屏障上下文中完成,任何漏掉的 volatile 读写都可能导致永远阻塞。

本站声明:本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn

热门AI工具

更多
PixTV
PixTV Hot

PixTV是一款面向AIGC内容创作的AI视频生成工具。

讯飞绘文

讯飞绘文是一款由科大讯飞推出的一站式 AIGC 内容运营平台。

DeepSeek

DeepSeek是一款面向对话、写作、编程和推理场景的AI大模型工具。

小橡皮AI

一款AI工具,主要用于小橡皮一键去AI味,将机器味重的内容改得更有活人感,防止因为 AI 内容被平台打上 AI 标签,以及限流,适合需要提升相关任务效率的用户。

豆包大模型

豆包大模型是一款由字节跳动推出的企业级大语言模型服务平台。

花生AI
花生AI Hot

一款AI视频创作工具,主要用于B站推出的AI视频创作工具,适合需要提升相关任务效率的用户。

音述AI
音述AI Hot

一款AI音频处理工具,主要用于音述AI是一个以“用声音述说故事”为核心的 AI 音乐创作与声音分享社区,适合需要提升相关任务效率的用户。

WorkBuddy

一款AI办公效率工具,主要用于腾讯云推出的AI原生桌面智能体工作台,适合需要提升相关任务效率的用户。

Seko
Seko Hot

一款AI视频创作工具,主要用于商汤科技推出的创编一体的AI短视频创作Agent,适合需要提升相关任务效率的用户。

相关专题

更多
while的用法
while的用法

while的用法是“while 条件: 代码块”,条件是一个表达式,当条件为真时,执行代码块,然后再次判断条件是否为真,如果为真则继续执行代码块,直到条件为假为止。本专题为大家提供while相关的文章、下载、课程内容,供大家免费下载体验。

354

2023.09.25

string转int
string转int

在编程中,我们经常会遇到需要将字符串(str)转换为整数(int)的情况。这可能是因为我们需要对字符串进行数值计算,或者需要将用户输入的字符串转换为整数进行处理。php中文网给大家带来了相关的教程以及文章,欢迎大家前来学习阅读。

7119

2023.08.02

int占多少字节
int占多少字节

int占4个字节,意味着一个int变量可以存储范围在-2,147,483,648到2,147,483,647之间的整数值,在某些情况下也可能是2个字节或8个字节,int是一种常用的数据类型,用于表示整数,需要根据具体情况选择合适的数据类型,以确保程序的正确性和性能。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

3405

2024.08.29

c++怎么把double转成int
c++怎么把double转成int

本专题整合了 c++ double相关教程,阅读专题下面的文章了解更多详细内容。

4448

2025.08.29

C++中int的含义
C++中int的含义

本专题整合了C++中int相关内容,阅读专题下面的文章了解更多详细内容。

3005

2025.08.29

c++中volatile关键字的作用
c++中volatile关键字的作用

本专题整合了c++中volatile关键字的相关内容,阅读专题下面的文章了解更多详细内容。

814

2025.10.23

线程和进程的区别
线程和进程的区别

线程和进程的区别:线程是进程的一部分,用于实现并发和并行操作,而线程共享进程的资源,通信更方便快捷,切换开销较小。本专题为大家提供线程和进程区别相关的各种文章、以及下载和课程。

4638

2023.08.10

Python 多线程与异步编程实战
Python 多线程与异步编程实战

本专题系统讲解 Python 多线程与异步编程的核心概念与实战技巧,包括 threading 模块基础、线程同步机制、GIL 原理、asyncio 异步任务管理、协程与事件循环、任务调度与异常处理。通过实战示例,帮助学习者掌握 如何构建高性能、多任务并发的 Python 应用。

1289

2025.12.24

DBeaver怎么导入数据
DBeaver怎么导入数据

DBeaver数据导入专题,整理Excel、CSV、SQL、TXT等常见文件的数据导入方法,涵盖目标数据库选择、数据表创建、字段映射、数据类型设置及导入参数配置等操作,帮助用户将本地文件中的数据写入数据库,并了解批量导入、重复数据处理和导入失败等常见问题的解决方法。

0

2026.11.05

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
热门推荐
/
最新课程
关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn