Java并发编程-重入锁
章节目录
- 什么是重入锁
- 底层实现-如何实现重入
- 公平与非公平获取锁的区别与底层实现
1.什么是重入锁
1.1 重入锁的定义
重入锁ReentrantLock，支持重入的锁，表示一个线程对资源的重复加锁。
1.2 重入锁的特性
1.重进入
2.非/公平性获取锁
1.3 自定义同步器Mutex 的缺陷
当线程调用Mutex的lock()方法获取锁之后，再次调用lock()方法，该线程将会被
自己阻塞，原因是Mutex在实现tryAcquire(int acquires)方法时没有考虑占有锁
的线程再次获取锁的场景。
1.4 ReentrantLock & synchronized 关键字
1.synchronized 关键字支持隐式的重进入
2.ReentrantLock 在调用lock() 方法时，已经获取到锁的线程，能够再次调用
lock()方法获取到锁而不被阻塞，即可支持重入
1.4 公平性获取锁
| 公平性 | 含义 |
|---|---|
| 公平性获取锁 | 在绝对时间上，先对锁进行获取请求的请求一定先被满足，那么这个锁就是公平的 |
| 非公平性获取锁 | 无上述限制 |
事实上 公平锁机制往往没有非公平性机制获取锁的效率高，因为会牵扯到频繁的上下文切换，但公平锁可以减少饥饿发生的概率，等待越久的请求越能得到优先满足。
2. 底层实现-如何实现重入
重进入是指任意线程在获取到锁之后能够再次获取该锁，而不被阻塞，改特性实现需要解决以下两个问题：
- 线程再次获取锁
线程再次获取锁。锁需要去识别获取锁的线程是否为当前占据锁的线程，如果是，则再次成功获取。 - 锁的最终释放
线程重复n次获取了锁，随后在第n次释放锁，锁的释放要求锁对于被获取递 增的次数进行递减操作，当计数==0时表示锁已经成功释放。
2.1 可重入锁的源码
非公平性获取同步状态(锁)的 nonfairTryAcquire() 方法
final boolean nonfairTryAcquire(int acquires) {
final Thread current = Thread.currentThread();
int c = getState();
if (c == 0) {
if (compareAndSetState(0, acquires)) {
setExclusiveOwnerThread(current);
return true;
}
}
else if (current == getExclusiveOwnerThread()) {
int nextc = c + acquires;
if (nextc < 0) // overflow
throw new Error("Maximum lock count exceeded");
setState(nextc);
return true;
}
return false;
}
该方法增加了再次获取同步状态的处理逻辑:通过判断当前线程是否为获取锁的线程来决定获取操作是否成功，如果是获取锁的线程的再次请求 则将同步状态值计数器进行递增并返回true，表示获取同步状态成功。
释放同步状态(锁)
protected final boolean tryRelease(int releases) {
int c = getState() - releases;
if (Thread.currentThread() != getExclusiveOwnerThread())
throw new IllegalMonitorStateException();
boolean free = false;
if (c == 0) {
free = true;
setExclusiveOwnerThread(null);
}
setState(c);
return free;
}
如果该锁被获取了n次，那么前n-1此tryRelease(int release) 方法必须返回false，而只有同步状态完全释放了，才能返回true。
3.公平与非公平获取锁的区别与底层实现
3.1 公平性获取锁的底层实现
公平性获取锁即按照客观时间顺序，FIFO方式获取同步状态
具体源码如下所示
protected final boolean tryAcquire(int acquires) {
final Thread current = Thread.currentThread();
int c = getState();
if (c == 0) {
if (!hasQueuedPredecessors() &&
compareAndSetState(0, acquires)) {
setExclusiveOwnerThread(current);
return true;
}
}
else if (current == getExclusiveOwnerThread()) {
int nextc = c + acquires;
if (nextc < 0)
throw new Error("Maximum lock count exceeded");
setState(nextc);
return true;
}
return false;
}
公平性获取同步状态的与非公平性获取同步状态的区别在于hasQueuedPredecessors()方法的使用，即加入了当前节点是否有前驱节点的判断，如果该方法返回true,则表示有线程比当前线程更早的加入到同步队列（更早的请求获取锁），因此需要等待前驱线程获取并释放锁之后才能继续获取锁。
非公平性获取锁的实现
- 公平性获取锁保证了锁的获取顺序按照FIFO原则，不会出现线程“饥饿”的现象，但代价是进行大量的线程切换。
- 非公平性锁虽然可能造成线程饥饿，但是有极少的线程切换，保证了其更大的吞吐量。
