聊聊高并发(十六)实现一个简单的可重入锁
可重入鎖指的是假設一個線程已經獲得了一個鎖,那么它能夠多次進入這個鎖,當然前提是線程須要先獲得這個鎖。
可重入鎖是最常使用的鎖。Java的內置鎖就是可重入鎖,使用synchronizedkeyword能夠啟用內置鎖機制,比方說一個類有兩個synchronized方法A和B。在A方法中調用了B方法,假設鎖不是可重入的。那么訪問B時須要再次競爭鎖。這樣會帶來死鎖。
public synchronized void A(){B();}public synchronized void B(){}可重入鎖攻克了這個問題,它使用一個計數器來記錄一個線程進入鎖的次數,每次進入鎖計數器就加1。釋放鎖減1。直到計數器為0時表示真正釋放了鎖。其它鎖看到計數器不為0時就知道有其它線程已經獲得了鎖。就須要等待。Java的內置鎖的基本原理也是這樣,JDK1.5之后提供了顯式鎖ReentrantLock也是這個基本原理。
以下實現一個簡單的可重入鎖。
1. 使用一個Thread引用指向獲得鎖的線程
2. 使用一個計數器記錄一個線程進入鎖的次數,當計數器為0時表示鎖是空暇的
3. 使用一個內部鎖Lock來同步線程
4. 使用一個isHoldZero的條件來進行條件隊列操作
5. 當獲得鎖的線程是自己時,僅僅改動計數器的值,直接獲得鎖
6. 當獲得鎖的線程不是自己時。須要在holdCount !=0 這個條件謂詞上等待。直到計數器歸0,再次競爭鎖
7. 釋放鎖時計數器減1,當計數器為0時。喚醒在條件隊列中等待的線程
package com.zc.lock;import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.ReentrantLock;/*** 簡單的可重入鎖實現,使用一個計數器記錄當前線程重入鎖的次數,獲得鎖時計數器加1,釋放鎖時計數器減1。當計數器等于0時表示釋放了鎖* **/
public class SimpleReentrantLock implements Lock{// 指向已經獲得鎖的線程private volatile Thread exclusiveOwnerThread;// 記錄獲取了同一個鎖的次數private volatile int holdCount;private final java.util.concurrent.locks.Lock lock;// 是否是自己獲得鎖的條件private final Condition isCountZero;public SimpleReentrantLock(){lock = new ReentrantLock();isCountZero = lock.newCondition();holdCount = 0;}@Overridepublic void lock() {lock.lock();try{// 當前線程的引用Thread currentThread = Thread.currentThread();// 假設獲得鎖的線程是自己,那么計數器加1,直接返回if(exclusiveOwnerThread == currentThread){holdCount ++;return;}while(holdCount != 0){try {isCountZero.await();} catch (InterruptedException e) {throw new RuntimeException("Interrupted");}}// 將exclusiveOwnerThread設置為自己exclusiveOwnerThread = currentThread;holdCount ++;}finally{lock.unlock();}}@Overridepublic void unlock() {lock.lock();try{holdCount --;if(holdCount == 0){isCountZero.signalAll();}}finally{lock.unlock();}}}轉載于:https://www.cnblogs.com/gcczhongduan/p/5080648.html
總結
以上是生活随笔為你收集整理的聊聊高并发(十六)实现一个简单的可重入锁的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: “何堪最长夜”下一句是什么
- 下一篇: 小米3屏幕多少钱啊?