首页 技术 正文
技术 2022年11月11日
0 收藏 770 点赞 4,939 浏览 2010 个字

ReentrantLock 是一种可重入的互斥锁,它不像 synchronized关键字一样支持隐式的重进入,但能够使一个线程(不同的方法)重复对资源的重复加锁而不受阻塞。

ReentrantLock 的 Java类图:

其中抽象静态内部类 Sync 继承了 AQS,可见 ReentrantLock 是通过组合自定义同步器来实现锁的获取与释放。

ReentrantLock 的构造函数能控制锁的公平性表现:

1     public ReentrantLock(boolean fair) {
2 sync = fair ? new FairSync() : new NonfairSync();
3 }

公平锁的够减少“饥饿”发生概率,等待越久的请求越能够优先的到满足。

公平性与否是针对获取锁而言的,一个锁若是公平的,那么锁的获取顺序就应该符合请求的绝对时间顺序,先到先得。

公平性锁每次都是从同步队列中的第一个节点获取到锁,而非公平性锁会出现一个线程连续获取锁的情况,特别是刚释放锁的线程在次获取同步状态的几率会更大,使得其他线程在同步队列中等待。

在系统线程上下文切换方面上,非公平性锁的切换次数会明显少于公平性锁,因为公平性锁的切换开销相对更大,但是极少的线程切换能保证更大吞吐量。

ReentrantLock 类代码的基本结构:

 1 public class ReentrantLock implements Lock, java.io.Serializable {
2 private final Sync sync;
3
4 //默认无参构造函数,默认为非公平锁
5 public ReentrantLock() {
6 sync = new NonfairSync();
7 }
8
9 //带参数的构造函数,决定是公平锁还是非公平锁
10 public ReentrantLock(boolean fair) {
11 sync = fair ? new FairSync() : new NonfairSync();
12 }
13
14 //抽象基类继承AQS,公平锁与非公平锁继承该类,并分别实现其lock()方法
15 abstract static class Sync extends AbstractQueuedSynchronizer {
16 abstract void lock();
17 //省略..
18 }
19
20 //非公平锁实现
21 static final class NonfairSync extends Sync {...}
22
23 //公平锁实现
24 static final class FairSync extends Sync {....}
25
26 //锁实现,根据具体子类实现调用
27 public void lock() {
28 sync.lock();
29 }
30
31 //响应中断的获取锁
32 public void lockInterruptibly() throws InterruptedException {
33 sync.acquireInterruptibly(1);
34 }
35
36 //尝试获取锁,默认采用非公平锁方法实现
37 public boolean tryLock() {
38 return sync.nonfairTryAcquire(1);
39 }
40
41 //超时获取锁
42 public boolean tryLock(long timeout, TimeUnit unit)
43 throws InterruptedException {
44 return sync.tryAcquireNanos(1, unit.toNanos(timeout));
45 }
46
47 //释放锁
48 public void unlock() {
49 sync.release(1);
50 }
51
52 //创建锁条件(从Condetion来理解,就是创建等待队列)
53 public Condition newCondition() {
54 return sync.newCondition();
55 }
56
57 //省略....
58 }

ReentrantLock 释放锁的方法,在抽象静态内部类 Sync 中,它会检查当前线程同步状态值(重复获取一次锁,状态值会增加),在释放同步状态时减少同步状态值,若该锁获取了 n 次,那么前(n-1)次返回的都是 false,只有同步状态完全释放了(c为0),才会把占有该资源的线程设置为空,并返回 true。

 1     protected final boolean tryRelease(int releases) {
2 int c = getState() - releases;
3 if (Thread.currentThread() != getExclusiveOwnerThread())
4 throw new IllegalMonitorStateException();
5 boolean free = false;
6 if (c == 0) {
7 free = true;
8 setExclusiveOwnerThread(null);
9 }
10 setState(c);
11 return free;
12 }
相关推荐
python开发_常用的python模块及安装方法
adodb:我们领导推荐的数据库连接组件bsddb3:BerkeleyDB的连接组件Cheetah-1.0:我比较喜欢这个版本的cheeta…
日期:2022-11-24 点赞:878 阅读:9,077
Educational Codeforces Round 11 C. Hard Process 二分
C. Hard Process题目连接:http://www.codeforces.com/contest/660/problem/CDes…
日期:2022-11-24 点赞:807 阅读:5,552
下载Ubuntn 17.04 内核源代码
zengkefu@server1:/usr/src$ uname -aLinux server1 4.10.0-19-generic #21…
日期:2022-11-24 点赞:569 阅读:6,401
可用Active Desktop Calendar V7.86 注册码序列号
可用Active Desktop Calendar V7.86 注册码序列号Name: www.greendown.cn Code: &nb…
日期:2022-11-24 点赞:733 阅读:6,176
Android调用系统相机、自定义相机、处理大图片
Android调用系统相机和自定义相机实例本博文主要是介绍了android上使用相机进行拍照并显示的两种方式,并且由于涉及到要把拍到的照片显…
日期:2022-11-24 点赞:512 阅读:7,813
Struts的使用
一、Struts2的获取  Struts的官方网站为:http://struts.apache.org/  下载完Struts2的jar包,…
日期:2022-11-24 点赞:671 阅读:4,896