前言
上一次咱们曾经讲了AQS
,如果对其不相熟的话倡议先去看看其实现原理,看完再来看ReentrantLock
就很简略了。
啃碎JDK源码(一):String
啃碎JDK源码(二):Integer
啃碎JDK源码(三):ArrayList
啃碎JDK源码(四):HashMap
啃碎JDK源码(五):ConcurrentHashMap
啃碎JDK源码(六):LinkedList
啃碎JDK源码(七):AbstractQueuedSynchronizer(AQS)
像 ReentrantLock
和 Synchornized
在面试中常常被用来比拟,如果想理解Synchronized
的话能够看我另外一篇文章:死磕Synchronized
注释
先来理解一下一些外围属性:
public class ReentrantLock implements Lock, java.io.Serializable {
// 实现AQS的外部类
private final Sync sync;
......
}
没错,ReentrantLock
没有什么值得注意的属性,因为曾经在AQS
中定义好了,咱们只须要继承它而后进行简略的实现即可。
先看下 ReentrantLock
的用法:
public static void main(String[] args) {
Lock lock = new ReentrantLock();
lock.lock();
try {
// 执行业务
Thread.sleep(1000);
} catch (Exception e) {
e.printStackTrace();
} finally {
lock.unlock();
}
}
只有调用 lock
办法就能够进行加锁操作,示意接下来的这段代码曾经被以后线程锁住,其余线程须要执行时须要拿到这个锁能力执行,而以后线程在执行完之后要显式的调用 unlock
开释锁。
留神:看源码之前你必须要对AQS
比拟相熟才行,能够参考我上一篇博客:
啃碎JDK源码(七):AbstractQueuedSynchronizer(AQS)
咱们来跟进源码看一下,先来看咱们的加锁lock
办法:
public void lock() {
sync.lock();
}
// Sync继承了AQS
abstract static class Sync extends AbstractQueuedSynchronizer {
abstract void lock();
......
}
能够看到是调用外部类的lock
办法,而它是一个形象办法,咱们看下谁继承了这个形象接口:
FairSync
和 NonfairSync
是 ReentrantLock
的另外两个外部类。顾名思义一个是偏心锁,一个是非偏心锁。(偏心锁就是永远都是队列的第一位能力失去锁)
在AQS
有一个同步队列(CLH
),是一种先进先出队列。偏心锁的意思就是严格依照这个队列的程序来获取锁,非偏心锁的意思就是不肯定依照这个队列的程序来。
在new对象的时候便会对sync初始化,如下:
public ReentrantLock() {
sync = new NonfairSync();
}
public ReentrantLock(boolean fair) {
sync = fair ? new FairSync() : new NonfairSync();
}
能够看出默认是非偏心锁,如果传true则初始化为偏心锁。
那咱们首先来看看非偏心锁:
static final class NonfairSync extends Sync {
private static final long serialVersionUID = 7316153563782823691L;
final void lock() {
// CAS批改状态
if (compareAndSetState(0, 1))
// 设置独占线程
setExclusiveOwnerThread(Thread.currentThread());
else
// 进入队列期待
acquire(1);
}
// tryAcquire是AQS的形象办法,咱们这里对其实现
protected final boolean tryAcquire(int acquires) {
return nonfairTryAcquire(acquires);
}
}
首先用 compareAndSetState
办法应用CAS批改state状态变量的值,如果批改胜利的话应用 setExclusiveOwnerThread(Thread.currentThread())
办法将以后线程设置为独占锁的持有线程,否则调用AQS的 acquire
办法进去队列期待解决。
接下来看一下acquire
办法:
public final void acquire(int arg) {
if (!tryAcquire(arg) &&
acquireQueued(addWaiter(Node.EXCLUSIVE), arg))
selfInterrupt();
}
该办法是AQS里的办法,咱们上次曾经介绍过了,这里间接截过去看下:
这次咱们次要关注由子类ReentrantLock
实现的tryAcquire
办法:
protected final boolean tryAcquire(int acquires) {
return nonfairTryAcquire(acquires);
}
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");
// 间接批改state遍历,因为曾经持有锁,不须要用CAS去批改
setState(nextc);
return true;
}
return false;
}
下面代码和咱们在上次手动实现一个可重入锁的代码差不多,这里就不再开展。
那接下来看一下 unlock
办法:
public void unlock() {
sync.release(1);
}
public final boolean release(int arg) {
// 尝试开释锁
if (tryRelease(arg)) {
Node h = head;
if (h != null && h.waitStatus != 0)
unparkSuccessor(h);
return true;
}
return false;
}
release
办法在AQS类中定义好了,咱们子类次要实现 tryRelease
办法:
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;
}
这段代码上篇文章咱们也曾经讲过了,如果遗记的同学能够回头看看。
看完非偏心锁的最初来看看偏心锁的加锁办法:
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
办法用来判断是否存在比期待更久的线程,因为要依照等待时间程序获取资源,其它的这里就不再细说了。
其它疑难
以下问题来自 从源码角度了解ReentrantLock
为什么基于FIFO的同步队列能够实现非偏心锁?
由FIFO队列的个性知,先退出同步队列期待的线程会比后退出的线程更凑近队列的头部,那么它将比后者更早的被唤醒,它也就能更早的失去锁。从这个意义上,对于在同步队列中期待的线程而言,它们取得锁的程序和退出同步队列的程序统一,这显然是一种偏心模式。然而,线程并非只有在退出队列后才有机会取得锁,哪怕同步队列中已有线程在期待,非偏心锁的不偏心之处就在于此。回看下非偏心锁的加锁流程,线程在进入同步队列期待之前有两次抢占锁的机会:
- 第一次是应用
compareAndSetState
办法尝试批改state变量,只有在以后锁未被任何线程占有(包含本身)时能力胜利。 - 第二次是在进入同步队列前应用
tryAcquire(arg)
尝试获取锁。
只有这两次获取锁都失败后,线程才会结构结点并退出同步队列期待。而线程开释锁时是先开释锁(批改state值),而后才唤醒后继结点的线程的。试想下这种状况,线程A曾经开释锁,但还没来得及唤醒后继线程C,而这时另一个线程B刚好尝试获取锁,此时锁恰好不被任何线程持有,它将胜利获取锁而不必退出队列期待。线程C被唤醒尝试获取锁,而此时锁曾经被线程B抢占,故而其获取失败并持续在队列中期待。
那咱们在开发中为什么大多应用非偏心锁?很简略,因为它性能好啊。
为什么非偏心锁性能好
- 线程不用退出期待队列就能够取得锁,不仅免去了结构结点并退出队列的繁琐操作,同时也节俭了线程阻塞唤醒的开销,线程阻塞和唤醒波及到线程上下文的切换和操作系统的零碎调用,是十分耗时的。。
- 缩小CAS竞争。如果线程必须要退出阻塞队列能力获取锁,那入队时CAS竞争将变得异样强烈,CAS操作尽管不会导致失败线程挂起,但一直失败重试导致的对CPU的节约也不能漠视。
总结
无关 ReentrantLock
的常识就介绍到这里了,有什么不对的中央请多多指教。
发表回复