首页 > 编程语言 >Java并发之ReentrantLock基础(一)

Java并发之ReentrantLock基础(一)

时间:2022-09-23 11:02:58浏览次数:53  
标签:Java AQS lock ReentrantLock Sync tryAcquire 并发 方法

ReentrantLock是Java中java.util.concurrent.locks.Lock的一个实现类,顾名思义它是Java中锁的一种实现,具体一点来说它是Java中一种可重入的独占锁。它与synchronized相比在功能上与之基本相同,但ReentrantLock提供了更为丰富灵活的使用方式,也更加适合复杂的并发场景。但是synchronized是基于JVM层面实现的,而Lock是基于JDK层面实现的。ReentrantLock内部通过内部类实现了AQS框架(AbstractQueuedSynchronizer)的API来实现独占锁的功能。

核心不同对比:

1. 类声明

ReentrantLock类

ReentrantLock的UML图

说明:ReentrantLock 类内部总共存在Sync、NonfairSync、FairSync三个类,NonfairSync与 FairSync类继承自 Sync类,Sync类继承自 AbstractQueuedSynchronizer抽象类。

2. 构造声明

ReentrantLock()构造,默认创建非公平策略(false)的ReentrantLock对象,即new ReentrantLock(false)。
ReentrantLock(boolean fair) 构造,fair参数可指定创建公平策略(true)/非公平策略(false)的ReentrantLock对象。

3. 使用方式

a)    ReentrantLock的基本使用

  • 在希望保证线程同步的代码之前显示调用 lock.lock() 尝试获取锁,若被其他线程占用则阻塞;
  • 在希望保证线程同步的代码执行完毕之后,需要手动释放锁lock.unlock(),否则会造成死锁(一般来讲把释放锁的逻辑放在需要线程同步的代码包装外的finally块中,以确保锁的释放);
  • 有N个lock.lock()就要有M(M=N)个lock.unlock(),若出现N>M则会造成死锁,若出现N<M< span="">则会抛出IllegalMonitorStateException异常;

b)   加锁和解锁

  • 加锁:

  • 通过ReentrantLock的加锁方法Lock进行加锁操作;
  • 会调用到内部类Sync的Lock方法,由于Sync#lock是抽象方法,根据ReentrantLock初始化选择的公平锁和非公平锁,执行相关内部类的Lock方法,本质上都会执行AQS的Acquire方法;
  • AQS的Acquire方法会执行tryAcquire方法,但是由于tryAcquire需要自定义同步器实现,因此执行了ReentrantLock中的tryAcquire方法,由于ReentrantLock是通过公平锁和非公平锁内部类实现的tryAcquire方法,因此会根据锁类型不同,执行不同的tryAcquire;
  • tryAcquire是获取锁逻辑,获取失败后,会执行框架 AQS的后续逻辑,跟ReentrantLock自定义同步器无关。
  • 解锁:

  • 通过 ReentrantLock的解锁方法 Unlock进行解锁;
  • Unlock会调用内部类 Sync的 Release方法,该方法继承于AQS;
  • Release中会调用 tryRelease方法,tryRelease需要自定义同步器实现,tryRelease只在ReentrantLock中的Sync实现,因此可以看出,释放锁的过程,并不区分是否为公平锁;
  • 释放成功后,所有处理由AQS框架完成,与自定义同步器无关。

标签:Java,AQS,lock,ReentrantLock,Sync,tryAcquire,并发,方法
From: https://www.cnblogs.com/shanxihualu/p/16721938.html

相关文章