線程互斥同步除了使用最基本的 synchronized 關(guān)鍵字外(關(guān)于 synchronized 關(guān)鍵字的實(shí)現(xiàn)原理风宁,請(qǐng)看之前寫的線程安全之 synchronized 關(guān)鍵字)选酗, Java 5 之后還提供了 API 可以實(shí)現(xiàn)同樣的功能,java.util.concurrent(簡(jiǎn)稱 J.U.C)下的重入鎖 ReentrantLock 不僅實(shí)現(xiàn)可重入的互斥鎖物邑,還有幾個(gè)高級(jí)功能:等待可中斷、可實(shí)現(xiàn)公平鎖坛掠、鎖可綁定多個(gè)條件耳璧、可限定最大等待時(shí)間。下面從基本使用到內(nèi)部實(shí)現(xiàn)格郁,層層分析 ReentrantLock 原理腹殿。
1. ReentrantLock 的用法
ReentrantLock 文檔中寫明了在 lock()
方法后,用 try 把同步代碼塊包起來(lái)例书,然后在 finally 中調(diào)用 unlock()
锣尉。這樣做的目的是保證解鎖操作一定會(huì)被調(diào)用,防止死鎖决采。
class X {
private final ReentrantLock lock = new ReentrantLock();
// ...
public void m() {
// block until condition holds
lock.lock();
try {
// ... method body
} finally {
lock.unlock();
}
}
}
ReentrantLock 還可以綁定多個(gè)條件自沧,下面使用 Condition 文檔中的例子來(lái)說(shuō)明:
class BoundedBuffer {
final Lock lock = new ReentrantLock();
// notFull 是 buffer 沒(méi)有到最大值的條件
final Condition notFull = lock.newCondition();
// notEmpty 是 buffer 不為空的條件
final Condition notEmpty = lock.newCondition();
// buffer 最大值為 100
final Object[] items = new Object[100];
int putptr, takeptr, count;
public void put(Object x) throws InterruptedException {
lock.lock();
try {
while (count == items.length)
// buffer 滿了就掛起,直到收到 notFull 的信號(hào)
notFull.await();
items[putptr] = x;
if (++ putptr == items.length) putptr = 0;
++ count;
// buffer 新增 item树瞭,發(fā)送 notEmpty 信號(hào)
notEmpty.signal();
} finally {
lock.unlock();
}
}
public Object take() throws InterruptedException {
lock.lock();
try {
while (count == 0)
// buffer 為空就掛起暂幼,直到收到 notEmpty 的信號(hào)
notEmpty.await();
Object x = items[takeptr];
if (++ takeptr == items.length) takeptr = 0;
-- count;
// buffer 取走 item,發(fā)送 notFull 信號(hào)
notFull.signal();
return x;
} finally {
lock.unlock();
}
}
}
2. ReentrantLock 的 API
ReentrantLock 實(shí)現(xiàn)了 Lock 和 Serializable 接口移迫,下面是它的一些關(guān)鍵 API旺嬉。
ReentrantLock() -- 默認(rèn)使用非公平鎖
ReentrantLock(boolean fair) -- 是否使用公平鎖
void lock() -- 獲取鎖,如果鎖被其他線程持有厨埋,則阻塞該線程
void lockInterruptibly() -- 獲取鎖邪媳,如果鎖被其他線程持有,則阻塞該線程荡陷,直到獲取鎖或被其他線程中斷雨效;如果獲取鎖之前或者在獲取過(guò)程的過(guò)程中線程中斷,則拋出中斷異常
boolean tryLock() -- 如果直接獲取鎖成功則返回 true废赞;如果鎖被其他線程持有徽龟,返回 false
boolean tryLock(long timeout, TimeUnit unit) -- 在等待時(shí)間內(nèi)獲取到鎖并且線程沒(méi)有被中斷,返回 true唉地;否則返回 false
void unlock() -- 釋放鎖据悔,如果該線程沒(méi)有持有鎖传透,則拋出異常
Condition newCondition() -- 返回一個(gè)與鎖關(guān)聯(lián)的 Condition 實(shí)例
boolean isHeldByCurrentThread() -- 當(dāng)前線程是否持有鎖
boolean isLocked() -- 鎖是否被任意線程持有
3. ReentrantLock 的內(nèi)部實(shí)現(xiàn)
先總體描述下 ReentrantLock 的大致實(shí)現(xiàn),有一個(gè)成員屬性 sync
极颓,所有的方法都是調(diào)用該屬性的方法朱盐。Sync
繼承 AbstractQueuedSynchronizer
(簡(jiǎn)稱 AQS),AQS 封裝了鎖和線程等待隊(duì)列的基本實(shí)現(xiàn)菠隆。Sync
有兩個(gè)子類 NonfairSync
和 FairSync
兵琳,分別對(duì)應(yīng)非公平鎖和公平鎖。AQS 內(nèi)部使用volatile int state
表示同步狀態(tài)骇径,在 ReentrantLock 中 state
表示占有線程對(duì)鎖的持有數(shù)量躯肌,為 0 表示鎖未被持有,為 1 表示鎖被某個(gè)線程持有破衔,> 1 表示鎖被某個(gè)線程持有多次(即重入)羡榴。
3.1 默認(rèn)非公平鎖的 lock()
非公平鎖的 lock() 的方法路線如下:
lock() -> NonfairSync.lock() -> AQS.compareAndSetState(0, 1)
-> AQS.acquire(1) -> NonfairSync.tryAcquire(1) -> Sync.nonfairTryAcquire(1)
-> AQS.acquireQueued(addWaiter(Node.EXCLUSIVE), 1)
下面一步步分析源碼:
final void NonfairSync.lock() {
// 鎖未被持有,則獲取鎖运敢,并將當(dāng)前線程設(shè)置為鎖的獨(dú)占線程
// 這里可能為其他線程剛剛釋放鎖校仑,還有其他線程在等待,但這時(shí)直接獲取传惠,所以是不公平的
if (compareAndSetState(0, 1))
setExclusiveOwnerThread(Thread.currentThread());
// 若鎖被持有迄沫,則調(diào)用 AQS.acquire(1) 方法
else
acquire(1);
}
protected final boolean AQS.compareAndSetState(int expect, int update) {
// 利用 sun.misc.Unsafe 的 CAS 原子操作
// 如果 state 的當(dāng)前值為 expect,則修改為 update卦方,返回 true
// 如果 state 的當(dāng)前值不為 expect羊瘩,返回 false
return unsafe.compareAndSwapInt(this, stateOffset, expect, update);
}
public final void AQS.acquire(int arg) {
// NonfairSync.tryAcquire(1) 方法只是調(diào)用了 Sync.nonfairTryAcquire(1)
// 先嘗試獲取鎖
if (!tryAcquire(arg) &&
// 獲取失敗則把線程添加到等待隊(duì)列中,并阻塞該線程直到獲取成功
acquireQueued(addWaiter(Node.EXCLUSIVE), arg))
selfInterrupt();
}
final boolean Sync.nonfairTryAcquire(int acquires) {
final Thread current = Thread.currentThread();
int c = getState();
if (c == 0) {
// 如果鎖未被持有盼砍,則直接獲取
// 這里可能為其他線程剛剛釋放鎖尘吗,還有其他線程在等待,但這時(shí)直接獲取浇坐,所以是不公平的
if (compareAndSetState(0, acquires)) {
setExclusiveOwnerThread(current);
return true;
}
}
else if (current == getExclusiveOwnerThread()) {
// 鎖被當(dāng)前線程持有睬捶,屬于重入,state ++
int nextc = c + acquires;
// 如果 state > 2 ^ 31 - 1, 則拋出異常近刘,這也是最大重入次數(shù)
if (nextc < 0) // overflow
throw new Error("Maximum lock count exceeded");
setState(nextc);
return true;
}
return false;
}
所以非公平鎖的 lock() 的大致邏輯為:如果鎖未被持有擒贸,不管等待隊(duì)列中的線程直接獲取觉渴;如果鎖被自己(當(dāng)前線程)持有介劫,則把 state
加 1;否則將當(dāng)前線程加入到等待隊(duì)列中案淋,并阻塞該線程直到獲取成功座韵。
關(guān)于AQS.acquireQueued()
的內(nèi)部實(shí)現(xiàn)在下一篇文章中專門分析 AQS 的內(nèi)部原理,阻塞線程是調(diào)用LockSupport.park()
方法實(shí)現(xiàn)的踢京。
LockSupport.park() 與線程中斷的關(guān)系
使用 Object.wait() 阻塞線程后誉碴,中斷阻塞線程會(huì)喚醒它并且清除中斷狀態(tài)然后拋出 InterruptedException宦棺。而 LockSupport.park() 阻塞線程后,線程中斷只會(huì)喚醒被阻塞的線程翔烁,沒(méi)有其他行為,和 unpark() 行為一致旨涝,所以需要判斷 Thread.interrupted()
來(lái)確定是否由中斷喚醒的蹬屹。
3.2 公平鎖的 lock()
公平鎖的 lock() 方法路線如下:
lock() -> FairSync.lock() -> AQS.acquire(1) -> FairSync.tryAcquire(1)
-> AQS.acquireQueued(addWaiter(Node.EXCLUSIVE), 1)
公平鎖與非公平鎖的主要區(qū)別在于 FairSync.tryAcquire(1) 這一步:
protected final boolean FairSync.tryAcquire(int acquires) {
final Thread current = Thread.currentThread();
int c = getState();
if (c == 0) {
// 如果鎖未被持有,并且當(dāng)前線程在等待隊(duì)列的頭部或者等待隊(duì)列為空白华,則獲取鎖
// 保證了沒(méi)有線程等待時(shí)間超過(guò)當(dāng)前線程慨默,所以是公平的
if (!hasQueuedPredecessors() &&
compareAndSetState(0, acquires)) {
setExclusiveOwnerThread(current);
return true;
}
}
else if (current == getExclusiveOwnerThread()) {
// 鎖被當(dāng)前線程持有,屬于重入弧腥,state ++
int nextc = c + acquires;
if (nextc < 0)
throw new Error("Maximum lock count exceeded");
setState(nextc);
return true;
}
return false;
}
所以公平鎖的 lock() 的大致邏輯為:如果鎖未被持有厦取,并且當(dāng)前線程在等待隊(duì)列的頭部或者等待隊(duì)列為空,則獲取鎖管搪;如果鎖被自己(當(dāng)前線程)持有虾攻,則把 state
加 1;否則將當(dāng)前線程加入到等待隊(duì)列中更鲁,并阻塞該線程霎箍。
3.3 可中斷的 lockInterruptibly()
lockInterruptibly() 方法的文檔介紹是獲取鎖除非線程中斷,首先看它的方法路線:
lockInterruptibly() -> AQS.acquireInterruptibly(1) -> throw new InterruptedException()
-> NonfairSync.tryAcquire(1) or FairSync.tryAcquire(1)
-> AQS.doAcquireInterruptibly(1)
下面看 acquireInterruptibly() 的源碼:
public final void AQS.acquireInterruptibly(int arg)
throws InterruptedException {
// 如果當(dāng)前線程是中斷的澡为,拋出 InterruptedException
if (Thread.interrupted())
throw new InterruptedException();
// 嘗試獲取鎖漂坏,即如果鎖未被持有或者已被當(dāng)前線程持有,直接獲取
if (!tryAcquire(arg))
// 獲取鎖失敗媒至,把線程添加到等待隊(duì)列顶别,阻塞線程,直到獲取成功或者線程中斷拒啰,線程中斷也會(huì)拋出 InterruptedException
doAcquireInterruptibly(arg);
}
從上面實(shí)現(xiàn)驯绎,可以發(fā)現(xiàn) lockInterruptibly() 與 lock() 的主要區(qū)別有兩點(diǎn):(1)如果此時(shí)線程是中斷的,那么直接拋出 InterruptedException 異常谋旦;(2)如果線程被阻塞条篷,在等待過(guò)程中線程中斷,拋出 InterruptedException 并取消獲取蛤织,從等待隊(duì)列中刪除赴叹。該方法可以用線程中斷防止長(zhǎng)時(shí)間阻塞,也可以以此退出死鎖指蚜。
3.4 非公平的 tryLock()
不管是公平鎖或者非公平鎖乞巧,tryLock() 方法都是使用非公平策略來(lái)嘗試獲取鎖,看它的路線圖:
tryLock() -> Sync.nonfairTryAcquire(1)
Sync.nonfairTryAcquire(1) 方法在默認(rèn)非公平鎖的 lock() 中分析過(guò)了摊鸡,如果鎖未被其他線程持有(兩種情況:1. 未被持有 2. 被自己持有)绽媒,則獲取鎖并返回 true蚕冬,否則返回 false。tryLock() 方法只是嘗試獲取鎖是辕,獲取失敗就會(huì)返回不會(huì)阻塞線程囤热,而使用 synchronized 關(guān)鍵字則會(huì)阻塞直到獲取鎖。
3.5 在限定時(shí)間內(nèi)的 tryLock(long timeout, TimeUnit unit)
先從方法實(shí)現(xiàn)看看與 tryLock() 的區(qū)別:
tryLock(long timeout, TimeUnit unit) -> AQS.tryAcquireNanos(1, unit.toNanos(timeout)) -> throw new InterruptedException()
-> NonfairSync.tryAcquire(1) or FairSync.tryAcquire(1)
-> AQS.doAcquireNanos(1, nanosTimeout)
AQS 的 tryAcquireNanos 方法源碼如下:
public final boolean AQS.tryAcquireNanos(int arg, long nanosTimeout)
throws InterruptedException {
// 如果當(dāng)前線程是中斷的获三,拋出 InterruptedException
if (Thread.interrupted())
throw new InterruptedException();
// 嘗試獲取鎖旁蔼,即如果鎖未被持有或者已被當(dāng)前線程持有,直接獲取
return tryAcquire(arg) ||
// 獲取失敗疙教,把線程添加到等待隊(duì)列棺聊,阻塞線程,直到限定時(shí)間贞谓、線程中斷或者在此之前獲取成功限佩,線程中斷也會(huì)拋出 InterruptedException
doAcquireNanos(arg, nanosTimeout);
}
可以看出 AQS.tryAcquireNanos(arg, nanosTimeout) 方法與 AQS.acquireInterruptibly(arg) 類似,都支持線程中斷裸弦,還加上了一個(gè)限定時(shí)間祟同。如果限定時(shí)間為 0,那么就相當(dāng)于調(diào)用 tryAcquire(1) 方法理疙。上面的 tryLock() 方法在公平鎖中還是使用非公平策略耐亏,但是 tryLock(0, TimeUnit.SECONDS) 在公平鎖中可以實(shí)現(xiàn)公平的 tryLock() 方法。
3.6 unlock()
unlock() 釋放持有的鎖沪斟,從獲取鎖的過(guò)程可以猜測(cè)到其中肯定會(huì)將 state 減 1广辰,但是具體的方法路線是如何呢?
unlock() -> AQS.release(1) -> Sync.tryRelease(1)
-> AQS.unparkSuccessor(head)
下面具體源碼:
public final boolean AQS.release(int arg) {
// 嘗試釋放鎖
if (tryRelease(arg)) {
Node h = head;
if (h != null && h.waitStatus != 0)
// 釋放成功主之,并等待隊(duì)列的第一個(gè)節(jié)點(diǎn)不為空择吊,使用 LockSupport.unpark() 喚醒第一個(gè)節(jié)點(diǎn)的線程
unparkSuccessor(h);
return true;
}
return false;
}
protected final boolean Sync.tryRelease(int releases) {
int c = getState() - releases;
if (Thread.currentThread() != getExclusiveOwnerThread())
// 當(dāng)前線程沒(méi)有持有鎖,拋出異常
throw new IllegalMonitorStateException();
boolean free = false;
if (c == 0) {
// state 為 0槽奕,鎖才是自由的几睛,否則只是退出一次重入,鎖的被持有線程不變
free = true;
setExclusiveOwnerThread(null);
}
setState(c);
// 返回釋放后鎖是否自由粤攒,即未被持有
return free;
}
所以 unlock() 方法實(shí)際是將 state 減 1所森,之后如果鎖是自由的,則會(huì)喚起等待隊(duì)列的頭節(jié)點(diǎn)中的線程夯接。不過(guò)在兩者中間焕济,如果有其他線程獲取鎖的話泻仙,公平鎖會(huì)判斷是否有線程等待浪汪,而非公平鎖則直接獲取該鎖坐榆。
3.7 isHeldByCurrentThread() 與 isLocked()
這兩個(gè)方法就比較簡(jiǎn)單了片挂,直接看對(duì)應(yīng)的源碼:
public boolean isHeldByCurrentThread() {
return sync.isHeldExclusively();
}
protected final boolean Sync.isHeldExclusively() {
// 判斷鎖的被持有線程是否為當(dāng)前線程
return getExclusiveOwnerThread() == Thread.currentThread();
}
public boolean isLocked() {
return sync.isLocked();
}
final boolean Sync.isLocked() {
return getState() != 0;
}
newCondition() 方法會(huì)在下面單獨(dú)描述绑嘹,而其他方法不是很重要鸠窗,這里就不再分析了尺借。
4. Condition
Condition 的作用與 Object 的 wait顶岸、notify、notifyAll 類似芍阎,用以線程間協(xié)作世曾。調(diào)用 Condition.await() 或 Object.wait() 將阻塞線程等待其他線程的通知,調(diào)用 Conditon.signal()谴咸、Condition.signalAll()轮听、Object.nofity()、Object.notifyAll() 將喚起 wait 的線程寿冕。
下面有幾個(gè)相關(guān)疑問(wèn)蕊程,可以仔細(xì)琢磨下椒袍。
為什么 Condition 與鎖相關(guān)驼唱,Object 的 wait、notify驹暑、notifyAll 與對(duì)象相關(guān)
先思考為什么 wait玫恳、notify、notifyAll 是 Object 的方法优俘,如果它們不和對(duì)象相關(guān)聯(lián)京办,wait() 阻塞線程后,notify() 喚起線程時(shí)不知道究竟喚醒哪些 wait 的線程帆焕,所以與某一對(duì)象對(duì)應(yīng)可以幫助 notify() 時(shí)喚醒的也是與該對(duì)象相關(guān)的等待線程惭婿。
為什么 await、signal 方法需要先獲取鎖叶雹,wait财饥、notify 方法需要先獲取對(duì)象鎖
這樣做的好處是保證 wait 和 notify 的過(guò)程是互斥的,而它們又要與某一個(gè)東西相關(guān)聯(lián)折晦,所以直接的方法與對(duì)象鎖相關(guān)聯(lián)钥星,實(shí)際不是與對(duì)象相關(guān)。所以 Condition 和 lock 相關(guān)聯(lián)满着。
4.1 Condition 的 API
await() -- 釋放相關(guān)的鎖谦炒,然后阻塞當(dāng)前線程直到被 singal 通知或者線程中斷
awaitUninterruptibly() -- 釋放相關(guān)的鎖,阻塞當(dāng)前線程直到被 singal 通知
awaitNanos(long nanosTimeout)风喇、await(long time, TimeUnit unit)宁改、awaitUntil(Date deadline) -- 釋放相關(guān)的鎖,阻塞當(dāng)前線程直到被 singal 通知魂莫、線程中斷或限定時(shí)間到
signal() -- 喚醒一個(gè)等待的線程透且,被喚醒的線程返回 await() 方法前需要重新獲取鎖
singalAll() -- 喚醒所有等待的線程,所有被喚醒的線程返回 await() 方法前需要重新獲取鎖
4.2 ReentrantLock 的 Condition 的內(nèi)部實(shí)現(xiàn)
下面看 await()、signal() 兩個(gè)方法的實(shí)現(xiàn)細(xì)節(jié)秽誊,ReentrantLock 返回的 Condition 是 AQS.ConditionObject 實(shí)例鲸沮。
public final void AQS.ConditionObject.await() throws InterruptedException {
// 如果線程中斷,直接拋出 InterruptedException
if (Thread.interrupted())
throw new InterruptedException();
// 先把當(dāng)前線程添加到 condition 的等待隊(duì)列中
Node node = addConditionWaiter();
// 釋放線程當(dāng)前持有的鎖
int savedState = fullyRelease(node);
int interruptMode = 0;
// 判斷線程是否被通知想重新獲取鎖
while (!isOnSyncQueue(node)) {
// 阻塞線程
LockSupport.park(this);
// 阻塞線程被喚醒后锅论,如果此時(shí)線程中斷讼溺,則跳出循環(huán)
if ((interruptMode = checkInterruptWhileWaiting(node)) != 0)
break;
}
// 所以阻塞線程被 signal 喚醒后,或者線程中斷后可以跳出循環(huán)
// 重新獲取鎖最易,獲取失敗則阻塞加入阻塞隊(duì)列直到獲取成功
if (acquireQueued(node, savedState) && interruptMode != THROW_IE)
// 如果獲取的過(guò)程中線程中斷怒坯,設(shè)置 interruptMode 為 REINTERRUPT
interruptMode = REINTERRUPT;
if (node.nextWaiter != null) // clean up if cancelled
// 清楚等待隊(duì)列中的取消的節(jié)點(diǎn)
unlinkCancelledWaiters();
if (interruptMode != 0)
// 如果 interruptMode 為 REINTERRUPT, 再次中斷線程
// 如果 interruptMode 為 THROW_IE,拋出 InterruptedException
reportInterruptAfterWait(interruptMode);
}
所以 awit() 的大致邏輯為:釋放鎖藻懒,并且阻塞自己并添加到 condition 的等待隊(duì)列剔猿,被 signal 通知或線程中斷后喚醒線程,重新獲取鎖嬉荆。
下面再看 signal() 方法的實(shí)現(xiàn):
public final void AQS.ConditionObject.signal() {
// 鎖不是互斥獨(dú)占鎖時(shí)归敬,拋出 IllegalMonitorStateException 異常
if (!isHeldExclusively())
throw new IllegalMonitorStateException();
Node first = firstWaiter;
if (first != null)
// 如果等待隊(duì)列不為空,
doSignal(first);
}
private void AQS.ConditionObject.doSignal(Node first) {
do {
// 把 first 節(jié)點(diǎn)從隊(duì)列中移除
if ( (firstWaiter = first.nextWaiter) == null)
lastWaiter = null;
first.nextWaiter = null;
// 循環(huán)找到第一個(gè)未取消的節(jié)點(diǎn)鄙早,把該節(jié)點(diǎn)從 condition 隊(duì)列添加到 sync 等待隊(duì)列(lock 隊(duì)列)
} while (!transferForSignal(first) &&
(first = firstWaiter) != null);
}
可以看到 signal() 并沒(méi)有喚起 wait 的線程汪茧,只是把等待時(shí)間最長(zhǎng)的未取消線程添加到 sync 等待隊(duì)列,等待獲取鎖限番。
而 signalAll() 方法的區(qū)別時(shí)將 condition 等待隊(duì)列中所有節(jié)點(diǎn)移到 sync 等待隊(duì)列舱污。
現(xiàn)在再來(lái)分析下,一開(kāi)始提供的 Condition 的 BoundedBuffer 示例弥虐,假設(shè)現(xiàn)在 BoundedBuffer 中 items 為空:
public Object take() throws InterruptedException {
lock.lock();
// 此時(shí)扩灯,線程 A 獲取到 lock
try {
while (count == 0)
// 因?yàn)?buffer 為空,釋放獲取的 lock霜瘪,阻塞線程珠插,添加到 notEmpty 等待隊(duì)列
notEmpty.await();
Object x = items[takeptr];
if (++ takeptr == items.length) takeptr = 0;
-- count;
// buffer 取走 item,發(fā)送 notFull 信號(hào)
notFull.signal();
return x;
} finally {
lock.unlock();
}
}
public void put(Object x) throws InterruptedException {
lock.lock();
// 然后粥庄,線程 B 獲取到 lock
try {
while (count == items.length)
// buffer 滿了就掛起丧失,直到收到 notFull 的信號(hào)
notFull.await();
items[putptr] = x;
if (++ putptr == items.length) putptr = 0;
++ count;
// 把 notEmpty 等待隊(duì)列中的線程 A 移到 lock 的等待隊(duì)列
notEmpty.signal();
} finally {
// 線程 B 釋放鎖,喚醒 lock 等待隊(duì)列中的線程 A惜互,線程 A 獲取到 lock 然后從 await() 方法返回
lock.unlock();
}
}
5. 總結(jié)
ReentrantLock 是 API 的重入鎖布讹,相對(duì) synchronized 關(guān)鍵字來(lái)說(shuō),額外支持公平鎖(synchronized 是非公平的)训堆、獲取鎖可中斷描验、可以限定獲取的最大時(shí)間、可以關(guān)聯(lián)多個(gè) Condition坑鱼。內(nèi)部主要實(shí)現(xiàn)細(xì)節(jié)是基于 AQS 的膘流,等待隊(duì)列是用鏈表結(jié)構(gòu)存儲(chǔ)的絮缅,阻塞隊(duì)列使用 LockSupport.park() 實(shí)現(xiàn)。
什么時(shí)候用 ReentrantLock?
JDK 1.6 之后呼股,synchronized 的性能優(yōu)化得和 ReentrantLock 差不多耕魄,所以在 synchronized 可以滿足條件的情況話,優(yōu)先使用 synchronized彭谁。