文档章节

一文带你理解Java中Lock的实现原理

天王盖地虎626
 天王盖地虎626
发布于 06/19 18:33
字数 1377
阅读 63
收藏 6

当多个线程需要访问某个公共资源的时候,我们知道需要通过加锁来保证资源的访问不会出问题。java提供了两种方式来加锁,一种是关键字:synchronized,一种是concurrent包下的lock锁。synchronized是java底层支持的,而concurrent包则是jdk实现。关于synchronized的原理可以阅读再有人问你synchronized是什么,就把这篇文章发给他。

在这里,我会用尽可能少的代码,尽可能轻松的文字,尽可能多的图来看看lock的原理。

我们以ReentrantLock为例做分析,其他原理类似。

我把这个过程比喻成一个做菜的过程,有什么菜,做法如何?

我先列出lock实现过程中的几个关键词:计数值、双向链表、CAS+自旋


使用例子

 

import java.util.concurrent.locks.ReentrantLock;

public class App {


    public static void main(String[] args) throws Exception {

        final int[] counter = {0};


        ReentrantLock lock = new ReentrantLock();


        for (int i= 0; i < 50; i++){

            new Thread(new Runnable() {

                @Override

                public void run() {

                    lock.lock();

                    try {

                        int a = counter[0];

                        counter[0] = a + 1;

                    }finally {

                        lock.unlock();

                    }

                }

            }).start();

        }


        // 主线程休眠,等待结果

        Thread.sleep(5000);

        System.out.println(counter[0]);

    }

}

在这个例子中,开50个线程同时更新counter。分成三块来看看源码(初始化、获取锁、释放锁)


实现原理

ReentrantLock() 干了啥

 
 /**

     * Creates an instance of {@code ReentrantLock}.

     * This is equivalent to using {@code ReentrantLock(false)}.

     */

    public ReentrantLock() {

        sync = new NonfairSync();

    }

在lock的构造函数中,定义了一个NonFairSync,

static final class NonfairSync extends Sync 

NonfairSync 又是继承于Sync

abstract static class Sync extends AbstractQueuedSynchronizer

一步一步往上找,找到了
这个鬼AbstractQueuedSynchronizer(简称AQS),最后这个鬼,又是继承于AbstractOwnableSynchronizer(AOS),AOS主要是保存获取当前锁的线程对象,代码不多不再展开。
最后我们可以看到几个主要类的继承关系。

f7ec178b93eeb15cc98dfac8732fea2159b79358

FairSync 与 NonfairSync的区别在于,是不是保证获取锁的公平性,因为默认是NonfairSync,我们以这个为例了解其背后的原理。

其他几个类代码不多,最后的主要代码都是在AQS中,我们先看看这个类的主体结构。

AbstractQueuedSynchronizer是个什么

 

57b7475d527d592e0c626776bf1238b76fa375cf


再看看Node是什么?

831781ec10901a1060ba59cb8947f7df339c15d9


看到这里的同学,是不是有种热泪盈眶的感觉,这尼玛,不就是双向链表么?我还记得第一次写这个数据结构的时候,发现居然还有这么神奇的一个东西。

最后我们可以发现锁的存储结构就两个东西:"双向链表" + "int类型状态"。
需要注意的是,他们的变量都被"transientvolatile修饰。

01ceee2dbde0eae7b901ab3bee596ad38866757c

一个int值,一个双向链表是如何烹饪处理锁这道菜的呢,Doug Lea大神就是大神,我们接下来看看,如何获取锁?

lock.lock()怎么获取锁?
/**

 * Acquires the lock.

 */
public void lock() {

    sync.lock();

}

可以看到调用的是,NonfairSync.lock()

5a7809035c292cf28cfb0eebd8202b11038c9f2c


看到这里,我们基本有了一个大概的了解,还记得之前AQS中的int类型的state值,这里就是通过CAS(乐观锁)去修改state的值。lock的基本操作还是通过乐观锁来实现的

获取锁通过CAS,那么没有获取到锁,等待获取锁是如何实现的?我们可以看一下else分支的逻辑,acquire方法:

public final void acquire(int arg) {

    if (!tryAcquire(arg) &&

        acquireQueued(addWaiter(Node.EXCLUSIVE), arg))

        selfInterrupt();

}

这里干了三件事情:

  • tryAcquire:会尝试再次通过CAS获取一次锁。

  • addWaiter:将当前线程加入上面锁的双向链表(等待队列)中

  • acquireQueued:通过自旋,判断当前队列节点是否可以获取锁。


addWaiter 添加当前线程到等待链表中 811ad99c49d08e940aeacd7becc8cb98e59cf190


可以看到,通过CAS确保能够在线程安全的情况下,将当前线程加入到链表的尾部。
enq是个自旋+上述逻辑,有兴趣的可以翻翻源码。

acquireQueued

c14e8bb94f0218794ac03e87c2e556eabd2451aa


可以看到,当当前线程到头部的时候,尝试CAS更新锁状态,如果更新成功表示该等待线程获取成功。从头部移除。

 

71e8b71038243dfaf21ebcf6f9fcc5fbaa659b08

最后简要概括一下,获取锁的一个流程

48c01d6093d60683cf2d842a26d7e407cfbcde7f

lock.unlock() 释放锁

 

public void unlock() {

    sync.release(1);

}

可以看到调用的是,NonfairSync.release()

7330906450a4f71f1d693be4a8c7b742d8466c84


最后有调用了NonfairSync.tryRelease()

f69fb329fa6298b88109b96e611db6ff925b445f


基本可以确认,释放锁就是对AQS中的状态值State进行修改。同时更新下一个链表中的线程等待节点。


总结
  • lock的存储结构:一个int类型状态值(用于锁的状态变更),一个双向链表(用于存储等待中的线程)

  • lock获取锁的过程:本质上是通过CAS来获取状态值修改,如果当场没获取到,会将该线程放在线程等待链表中。

  • lock释放锁的过程:修改状态值,调整等待链表。

  • 可以看到在整个实现过程中,lock大量使用CAS+自旋。因此根据CAS特性,lock建议使用在低锁冲突的情况下。目前java1.6以后,官方对synchronized做了大量的锁优化(偏向锁、自旋、轻量级锁)。因此在非必要的情况下,建议使用synchronized做同步操作。

最后,希望我的分析,能对你理解锁的实现有所帮助。

 

本文转载自:https://yq.aliyun.com/articles/640868

天王盖地虎626

天王盖地虎626

粉丝 32
博文 527
码字总数 20708
作品 0
南京
私信 提问
Java偏向锁实现原理(Biased Locking)

Java 偏向锁(Biased Locking)是Java6引入的一项多线程优化。它通过消除资源无竞争情况下的同步原语,进一步提高了程序的运行性能。 轻量级锁也是一种多线程优化,它与偏向锁的区别在于,轻量...

红薯
2010/04/10
559
0
【Java并发专题】27篇文章详细总结Java并发基础知识

努力的意义,就是,在以后的日子里,放眼望去全是自己喜欢的人和事! github:https://github.com/CL0610/Java-concurrency,欢迎题issue和Pull request。所有的文档都是自己亲自码的,如果觉...

你听___
2018/05/06
0
0
【并发编程】一文带你读懂深入理解Java内存模型(面试版本)

     并发编程这一块内容,是高级资深工程师必备知识点,25K起如果不懂并发编程,那基本到顶。但是并发编程内容庞杂,如何系统学习?本专题将会系统讲解并发编程的所有知识点,包括但不限...

java进阶架构师
2018/12/26
0
0
Java轻量级锁原理详解(Lightweight Locking)

大家知道,Java的多线程安全是基于Lock机制实现的,而Lock的性能往往不如人意。 原因是,monitorenter与monitorexit这两个控制多线程同步的bytecode原语,是JVM依赖操作系统互斥(mutex)来实现...

serenity
2015/08/11
507
0
Java并发学习之Volatile及内存模型探究

volatile工作原理 java编程语言允许线程访问共享变量,为了确保共享变量能被准确和一致的更新,线程应该确保通过排他锁单独获得这个变量。 Java语言提供了volatile,在某些情况下比锁更加方便...

小灰灰Blog
2017/11/02
45
0

没有更多内容

加载失败,请刷新页面

加载更多

精华帖

第一章 jQuery简介 jQuery是一个JavaScript库 jQuery具备简洁的语法和跨平台的兼容性 简化了JavaScript的操作。 在页面中引入jQuery jQuery是一个JavaScript脚本库,不需要特别的安装,只需要...

流川偑
9分钟前
3
0
语音对话英语翻译在线翻译成中文哪个方法好用

想要进行将中文翻译成英文,或者将英文翻译成中文的操作,其实有一个非常简单的工具就能够帮助完成将语音进行翻译转换的软件。 在应用市场或者百度手机助手等各大应用渠道里面就能够找到一款...

401恶户
21分钟前
1
0
jenkins 插件下载加速最终方案

推荐做法 1、告诉jenkins 我哪些插件需要更新 jenkins插件清华大学镜像地址 https://mirrors.tuna.tsinghua.edu.cn/jenkins/updates/update-center.json 1.进入jenkins系统管理 2.进入插件管...

vasks
27分钟前
3
0
composer爆错:zlib_decode():data error

解决办法:先用 composer diagnose 命令检测 然后 composer self-update 更新composer版本 最后执行 composer update 或者 composer install composer 切换阿里云镜像 用起来还快 composer c...

koothon
33分钟前
3
0
shangcheng-my

1.数据库主键、外键类型为bigint,那么在后台应该用什么类型的变量定义? 后台用string接收,因为前段传过来的一般都是json字符串,后台直接接收,mysql是可以吧数字类型的字符串转换为对应的...

榴莲黑芝麻糊
昨天
4
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部