news 2026/2/6 21:04:24

揭秘JUC:volatile与CAS,并发编程的两大基石

作者头像

张小明

前端开发工程师

1.2k 24
文章封面图
揭秘JUC:volatile与CAS,并发编程的两大基石

UC(java.util.concurrent)并发包,作为Java语言并发编程的利器,由并发编程领域的泰斗道格·利(Doug Lea)精心打造。它提供了一系列高效、线程安全的工具类、接口及原子类,极大地简化了并发编程的开发流程与管理复杂度。

JUC并发包与happens-before、内存语义的关系

image

探索JUC并发包,会发现它与Java内存模型中的happens-before原则及内存语义紧密相连。从高层视角俯瞰,volatile关键字与CAS(Compare-And-Swap)操作构成了JUC并发包底层实现的核心基石。接下来,以并发工具Lock为例,剖析其背后的实现机制。

class LockExample {

int x = 0;

Lock lock = new ReentrantLock();

public void set() {

// 获取锁

lock.lock();

try {

x = 1;

} finally {

// 释放锁

lock.unlock();

}

}

public void get() {

// 获取锁

lock.lock();

try {

int i = x;

// ......

} finally {

// 释放锁

lock.unlock();

}

}

}

Lock的实现依赖于Java同步器框架(AbstractQueuedSynchronizer,AQS)。AQS内部维护了一个由volatile修饰的整型变量state,用于表示同步状态。

‌ 1)获取锁‌:当调用Lock的lock()方法时,会触发AQS的tryAcquire()方法尝试获取锁。该方法首先检查当前state是否为0(表示锁未被占用),若是,则通过CAS操作将state设置为1,并标记当前线程为锁的持有者。若锁已被当前线程持有(即重入锁情况),则直接增加state的值。

‌ 2)释放锁‌:当调用Lock的unlock()方法时,会触发AQS的tryRelease()方法释放锁。该方法首先减少state的值,若减少后state为0,则表示锁已完全释放,同时清除锁的持有者信息。

// 关键volatile变量

private volatile int state;

protected final boolean tryAcquire(int acquires) {

// 1 获取到当前线程

final Thread current = Thread.currentThread();

// 2 获取到当前锁的state值

int c = getState();

// 3 如果state值为0,则是无线程占用锁

if (c == 0) {

// 4 compareAndSetState则通过CAS对state进行设置为1

if (compareAndSetState(0, acquires)) {

// 5 设置占用线程为当前线程并返回true

setExclusiveOwnerThread(current);

return true;

}

}

// 6 如果state不为0,并且当前线程等于锁占用的线程,则说明锁重入了。

else if (current == getExclusiveOwnerThread()) {

// 7 直接将state设置为+1

int nextc = c + acquires;

if (nextc < 0)

throw new Error("Maximum lock count exceeded");

setState(nextc);

return true;

}

// 8 如果是false,则说明是其他线程,直接返回false。

return false;

}

protected final boolean tryRelease(int releases) {

// 1 对state进行减值

int c = getState() - releases;

// 2 判断当前线程等于锁占用的线程

if (Thread.currentThread() != getExclusiveOwnerThread())

throw new IllegalMonitorStateException();

boolean free = false;

// 3 当c值为0,代表释放锁成功

if (c == 0) {

free = true;

// 4 设置为当前锁没有线程独占

setExclusiveOwnerThread(null);

}

// 5 将state重新置为0,意味其他线程可以重新抢锁

setState(c);

// 6 释放锁成功

return free;

}

从上述代码中,可以观察到volatile变量state在锁获取与释放过程中的关键作用。根据volatile的happens-before规则,释放锁的线程在修改volatile变量之前对共享变量的修改,对于后续获取该锁的线程来说是可见的。这确保了锁机制的正确性与线程间的数据一致性。

为了更直观地理解Lock的获取与释放过程,我们可以将其简化为如下伪代码。

class SimplifiedLockExample {

int x = 0;

volatile int state;

public void set() {

// 当前线程从主内存读取state值

while(state != 0) {

// 伪代码 阻塞当前线程

park(Thread.currentThread())

}

// CAS操作,确保只有一个线程能成功设置state为1

compareAndSwap(state, 1)

// 赋值操作,受volatile内存语义保护,防止重排序

x = 1;

// 释放锁,将state重置为0

state = 0;

// 唤醒其他等待线程

unpark(nonCurrentThread());

}

public void get() {

// 当前线程从主内存读取state值

while(state != 0) {

// 阻塞当前线程,等待锁释放

park(Thread.currentThread())

}

// CAS操作,尝试获取锁

compareAndSwap(state, 1)

// 读取共享变量x的最新值

int i = x;

// 其他操作...

// 释放锁,将state重置为0

state = 0;

// 唤醒其他等待线程

unpark(nonCurrentThread());

}

// 伪代码方法,实际实现需依赖底层系统调用

private void park(Thread thread)

private void unpark(Thread thread)

private boolean compareAndSwap(int expect, int newValue, int updateValue)

private Thread nonCurrentThread()

}

Java的CAS会使用现代处理器上提供的原子指令,实现无锁的线程安全更新机制。同时,volatile变量的读/写可以实现线程线程之间的通信。如果仔细分析JUC并发包的源代码实现,会发现一个通用化的实现模式。

‌ 1)声明共享变量为volatile‌:确保变量的可见性与有序性。

‌ 2)使用CAS的原子条件更新‌:实现线程间的同步与数据的一致性更新。

‌ 3)配合volatile的读/写内存语义‌:实现线程间的通信与数据传递。

这一模式在AQS、非阻塞数据结构(如ConcurrentHashMap)及原子变量类(如AtomicInteger)等JUC并发包的基础类中得到了广泛应用。而这些基础类又进一步支撑了JUC并发包中高层类的实现,构建了一个层次分明、功能强大的并发编程框架。

版权声明: 本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若内容造成侵权/违法违规/事实不符,请联系邮箱:809451989@qq.com进行投诉反馈,一经查实,立即删除!
网站建设 2026/2/4 16:10:13

Llama-Index RAG 进阶:小索引大窗口 + 混合检索 + 智能路由实战指南

Llama-Index RAG进阶检索策略实战指南 你的 RAG 为何总是“答非所问”&#xff1f;打破从 Demo 到生产的最后一道墙 “明明 Demo 跑得好好的&#xff0c;怎么一上线就‘翻车’&#xff1f;” 这是无数开发者在构建 RAG&#xff08;检索增强生成&#xff09;应用时面临的真实崩…

作者头像 李华
网站建设 2026/2/4 2:26:29

亚马逊卖家容易失误的3个坑,有人这样做亏了10w!

亚马逊卖家最怕的&#xff1a;不是赚得少&#xff0c;而是低级失误直接赔到倾家荡产&#xff01; 分享刷到一个去年的真实案例&#xff0c;简直让人看完背后发凉&#x1f631;&#xff1a;有个运营想给产品冲销量&#xff0c;先在站外社交平台扔了个折扣码。结果没过一两个小时…

作者头像 李华
网站建设 2026/2/3 6:24:56

直接上手玩转遗传算法,先搞个简单的函数最值问题热热身。比如找f(x)=x²的最小值,这玩意儿小学生都能秒答,但咱们用遗传算法折腾一下。先看看种群初始化代码

#MATLAB编写遗传算法&#xff0c;基于遗传算法求解TSP问题及函数最值最值问题。 #程序包含详细注释&#xff0c;本人在2020a版本均可运行。% 种群初始化 population_size 50; gene_length 20; % 二进制编码长度 population randi([0 1], population_size, gene_length); 这里…

作者头像 李华
网站建设 2026/2/4 0:10:42

【光照】[PBR][镜面反射]实现方法解析

微表面理论的核心概念微表面理论是一种物理渲染模型&#xff0c;它将宏观表面视为由无数微观几何细节&#xff08;微表面&#xff09;组成的复杂结构。这一理论是Unity URP中PBR&#xff08;基于物理的渲染&#xff09;实现的基础。基本假设‌微观结构‌&#xff1a;宏观表面由…

作者头像 李华
网站建设 2026/2/3 22:50:27

JavaScript学习笔记:15.迭代器与生成器

JavaScript学习笔记&#xff1a;15.迭代器与生成器 上一篇用类型数组搞定了二进制数据的“高效存储”&#xff0c;这一篇咱们解锁JS遍历的“终极形态”——迭代器&#xff08;Iterators&#xff09;与生成器&#xff08;Generators&#xff09;。你肯定用过for循环遍历数组&…

作者头像 李华
网站建设 2026/2/3 6:08:46

探索Comsol/CST狄拉克半金属BDS超材料:Matlab脚本与CST模型分享

Comsol/CST狄拉克半金属BDS超材料。 matlab脚本&#xff0c;送几个CST模型嘿&#xff0c;各位技术同好们&#xff01;今天来聊聊超有趣的Comsol/CST狄拉克半金属BDS超材料。狄拉克半金属近年来在材料物理和电磁学领域那可是相当热门&#xff0c;而基于它的BDS超材料更是展现出独…

作者头像 李华