線程安全之 ReentrantLock 完全解析

線程互斥同步除了使用最基本的 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è)子類 NonfairSyncFairSync兵琳,分別對(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彭谁。

最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
  • 序言:七十年代末,一起剝皮案震驚了整個(gè)濱河市缠局,隨后出現(xiàn)的幾起案子则奥,更是在濱河造成了極大的恐慌,老刑警劉巖狭园,帶你破解...
    沈念sama閱讀 206,723評(píng)論 6 481
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件读处,死亡現(xiàn)場(chǎng)離奇詭異,居然都是意外死亡唱矛,警方通過(guò)查閱死者的電腦和手機(jī)罚舱,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 88,485評(píng)論 2 382
  • 文/潘曉璐 我一進(jìn)店門,熙熙樓的掌柜王于貴愁眉苦臉地迎上來(lái)揖赴,“玉大人馆匿,你說(shuō)我怎么就攤上這事抑胎≡锘” “怎么了?”我有些...
    開(kāi)封第一講書人閱讀 152,998評(píng)論 0 344
  • 文/不壞的土叔 我叫張陵阿逃,是天一觀的道長(zhǎng)铭拧。 經(jīng)常有香客問(wèn)我,道長(zhǎng)恃锉,這世上最難降的妖魔是什么搀菩? 我笑而不...
    開(kāi)封第一講書人閱讀 55,323評(píng)論 1 279
  • 正文 為了忘掉前任,我火速辦了婚禮破托,結(jié)果婚禮上肪跋,老公的妹妹穿的比我還像新娘。我一直安慰自己土砂,他們只是感情好州既,可當(dāng)我...
    茶點(diǎn)故事閱讀 64,355評(píng)論 5 374
  • 文/花漫 我一把揭開(kāi)白布。 她就那樣靜靜地躺著萝映,像睡著了一般吴叶。 火紅的嫁衣襯著肌膚如雪。 梳的紋絲不亂的頭發(fā)上序臂,一...
    開(kāi)封第一講書人閱讀 49,079評(píng)論 1 285
  • 那天蚌卤,我揣著相機(jī)與錄音,去河邊找鬼。 笑死逊彭,一個(gè)胖子當(dāng)著我的面吹牛咸灿,可吹牛的內(nèi)容都是我干的。 我是一名探鬼主播侮叮,決...
    沈念sama閱讀 38,389評(píng)論 3 400
  • 文/蒼蘭香墨 我猛地睜開(kāi)眼析显,長(zhǎng)吁一口氣:“原來(lái)是場(chǎng)噩夢(mèng)啊……” “哼!你這毒婦竟也來(lái)了签赃?” 一聲冷哼從身側(cè)響起谷异,我...
    開(kāi)封第一講書人閱讀 37,019評(píng)論 0 259
  • 序言:老撾萬(wàn)榮一對(duì)情侶失蹤,失蹤者是張志新(化名)和其女友劉穎锦聊,沒(méi)想到半個(gè)月后歹嘹,有當(dāng)?shù)厝嗽跇?shù)林里發(fā)現(xiàn)了一具尸體,經(jīng)...
    沈念sama閱讀 43,519評(píng)論 1 300
  • 正文 獨(dú)居荒郊野嶺守林人離奇死亡孔庭,尸身上長(zhǎng)有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點(diǎn)故事閱讀 35,971評(píng)論 2 325
  • 正文 我和宋清朗相戀三年尺上,在試婚紗的時(shí)候發(fā)現(xiàn)自己被綠了。 大學(xué)時(shí)的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片圆到。...
    茶點(diǎn)故事閱讀 38,100評(píng)論 1 333
  • 序言:一個(gè)原本活蹦亂跳的男人離奇死亡怎抛,死狀恐怖,靈堂內(nèi)的尸體忽然破棺而出芽淡,到底是詐尸還是另有隱情马绝,我是刑警寧澤,帶...
    沈念sama閱讀 33,738評(píng)論 4 324
  • 正文 年R本政府宣布挣菲,位于F島的核電站富稻,受9級(jí)特大地震影響,放射性物質(zhì)發(fā)生泄漏白胀。R本人自食惡果不足惜椭赋,卻給世界環(huán)境...
    茶點(diǎn)故事閱讀 39,293評(píng)論 3 307
  • 文/蒙蒙 一、第九天 我趴在偏房一處隱蔽的房頂上張望或杠。 院中可真熱鬧哪怔,春花似錦、人聲如沸向抢。這莊子的主人今日做“春日...
    開(kāi)封第一講書人閱讀 30,289評(píng)論 0 19
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽(yáng)笋额。三九已至元暴,卻和暖如春,著一層夾襖步出監(jiān)牢的瞬間兄猩,已是汗流浹背茉盏。 一陣腳步聲響...
    開(kāi)封第一講書人閱讀 31,517評(píng)論 1 262
  • 我被黑心中介騙來(lái)泰國(guó)打工鉴未, 沒(méi)想到剛下飛機(jī)就差點(diǎn)兒被人妖公主榨干…… 1. 我叫王不留,地道東北人鸠姨。 一個(gè)月前我還...
    沈念sama閱讀 45,547評(píng)論 2 354
  • 正文 我出身青樓铜秆,卻偏偏與公主長(zhǎng)得像,于是被迫代替她去往敵國(guó)和親讶迁。 傳聞我的和親對(duì)象是個(gè)殘疾皇子连茧,可洞房花燭夜當(dāng)晚...
    茶點(diǎn)故事閱讀 42,834評(píng)論 2 345

推薦閱讀更多精彩內(nèi)容

  • 前言 上一篇文章《基于CAS操作的Java非阻塞同步機(jī)制》 分析了非同步阻塞機(jī)制的實(shí)現(xiàn)原理,本篇將分析一種以非同步...
    Mars_M閱讀 4,791評(píng)論 5 9
  • 第三章 Java內(nèi)存模型 3.1 Java內(nèi)存模型的基礎(chǔ) 通信在共享內(nèi)存的模型里巍糯,通過(guò)寫-讀內(nèi)存中的公共狀態(tài)進(jìn)行隱...
    澤毛閱讀 4,341評(píng)論 2 22
  • 作者: 一字馬胡 轉(zhuǎn)載標(biāo)志 【2017-11-03】 更新日志 前言 在java中啸驯,鎖是實(shí)現(xiàn)并發(fā)的關(guān)鍵組件,多個(gè)...
    一字馬胡閱讀 44,144評(píng)論 1 32
  • 整體方位偏左祟峦,投射過(guò)去生活和感情世界罚斗,整體繪制比較詳近,作者很注意生活細(xì)節(jié)宅楞,房屋中擺放的書针姿、茶杯、相片等表示作者將...
    藍(lán)田_b685閱讀 96評(píng)論 0 1
  • 水上萍閱讀 1,708評(píng)論 2 9