免费视频淫片aa毛片_日韩高清在线亚洲专区vr_日韩大片免费观看视频播放_亚洲欧美国产精品完整版

打開APP
userphoto
未登錄

開通VIP,暢享免費電子書等14項超值服

開通VIP
談?wù)凧ava中的那些鎖

公平鎖和非公平鎖

1、什么是公平鎖?什么是非公平鎖?

  • 公平鎖:是指多個線程按照申請鎖的順序來獲取鎖,也就是說按秩序排隊,先來后到。

  • 非公平鎖:是指多個線程獲取鎖的順序并不是按照申請鎖的順序來的。就像排隊打飯,總有些高年級同學(xué)會插隊。在高并發(fā)情況下,有可能會造成優(yōu)先級反轉(zhuǎn)或者饑餓現(xiàn)象(優(yōu)先級反轉(zhuǎn)好理解,就是本來輪到排在隊頭那個人打飯了,但是突然一人插隊跑前面了,這就是優(yōu)先級反轉(zhuǎn);如果一直有人插隊,那么僅管這個同學(xué)已經(jīng)排在隊頭了,但是還是一直沒吃上飯,這就是饑餓現(xiàn)象)。

2、兩者區(qū)別:
在并發(fā)環(huán)境中,每個線程獲取鎖時都會查看此鎖維護(hù)的等待隊列,如果為空,或者當(dāng)前線程是等待隊列的第一個,就占鎖,否則就加入到等待隊列中。而非公平鎖比較粗魯,上來就嘗試占鎖,如果占鎖失敗,就采用類似公平鎖的那種方式。非公平鎖性能比較好,吞吐量比較大。ReentrantLock實例化的時候可以傳入?yún)?shù)true或者false指定創(chuàng)建公平鎖還是非公平鎖,true是公平鎖,false是非公平鎖,不傳默認(rèn)是false。而synchronized也是非公平鎖。

可重入鎖

1、什么是可重入鎖?
可重入鎖又叫遞歸鎖。指的是外層函數(shù)獲得鎖之后,它可以進(jìn)入它所同步著的所有代碼,即使內(nèi)層函數(shù)也被鎖住,,也無需重新獲取鎖。

1public synchronized void method1(){
2        method2();
3}
4public synchronized void method2(){
5
6}

method1是加了鎖的,method2也是加了鎖的,然后在method1里面調(diào)用method2。當(dāng)method1獲取了鎖之后,調(diào)用的method2雖然也是加了鎖的,但是不用重新獲取鎖了,這就叫可重入鎖。也就說,可以理解為method1和method2獲取到的鎖可以理解為同一把鎖。ReentrantLock和synchronized都是可重入鎖。可重入鎖最大的作用就是防止死鎖。

2、可重入鎖demo:

  • 驗證synchronized是可重入鎖:

 1public class LockDemo {
2    public synchronized void fun1(){
3        System.out.println(Thread.currentThread().getId() + "執(zhí)行fun1方法");
4        fun2();
5    }
6    public synchronized void fun2(){
7        System.out.println(Thread.currentThread().getId() + "執(zhí)行fun2方法");
8    }
9
10    public static void main(String[] args){
11           LockDemo lockDemo = new LockDemo();
12           new Thread( () -> lockDemo.fun1()).start();
13    }
14}

看這段代碼,fun1一個同步方法,在里面輸出一句話,然后又調(diào)用了同步方法fun2。最后在main方法里面創(chuàng)建一個線程去執(zhí)行fun1方法。如果synchronized是可重入鎖,那么打印這兩個輸出語句的應(yīng)該是同一個線程。

運行結(jié)果
  • 驗證ReentrantLock是可重入鎖:

 1public class LockDemo {
2    public  void fun1(){
3        ReentrantLock lock = new ReentrantLock();
4        lock.lock();
5        try {
6            System.out.println(Thread.currentThread().getName() + ": 執(zhí)行fun1方法");
7            fun2();
8        }finally {
9            lock.unlock();
10        }
11    }
12    public  void fun2(){
13        ReentrantLock lock = new ReentrantLock();
14        lock.lock();
15        try {
16            System.out.println(Thread.currentThread().getName() + ": 執(zhí)行fun2方法");
17        }finally {
18            lock.unlock();
19        }
20    }
21
22    public static void main(String[] args){
23           LockDemo lockDemo = new LockDemo();
24           new Thread( () -> lockDemo.fun1()).start();
25    }
26}

這段代碼只不過把synchronized換成了lock鎖,運行結(jié)果是一樣的。以上兩端代碼說明synchronized和ReentrantLock都是可重入鎖。

自旋鎖

前面聊CAS的時候說到了它底層用的就是UnSafe類和自旋鎖。這里就詳細(xì)說一說自旋鎖。
1、什么是自旋鎖?
我們知道像synchronized和ReentrantLock鎖,當(dāng)這個線程沒有獲取到鎖的時候就是阻塞狀態(tài)。而自旋鎖就是采用循環(huán)的方式去嘗試獲取鎖,這樣的好處就是減少上下文切換的消耗,但是比較消耗CPU資源。再來看看原子包裝類的getAddIncrement方法:

1public final int getAndAddInt(Object var1, long var2, int var4) {
2        int var5;
3        do {
4            var5 = this.getIntVolatile(var1, var2);
5        } while(!this.compareAndSwapInt(var1, var2, var5, var5 + var4));
6        return var5;
7 }

當(dāng)while條件不成立時,就會一直執(zhí)行do語句,所以很消耗CPU。

舉個生活中的例子再來說明一下什么是自旋鎖:小明同學(xué)遇到了個問題,跑到講臺邊上去問老師??墒沁@時候老師在打電話,沒辦法立即給小明解答。小明就站在邊上干等著。這是小明就處于阻塞狀態(tài),做不了其他事。而自旋鎖就是,小明看到老師現(xiàn)在沒時間,就先回到座位上寫作業(yè),過一會兒再上去看,老師還沒時間,小明又回去做其他事。就這樣不斷的嘗試,知道成功。

2、手寫自旋鎖:

 1public class MyLock {
2    AtomicReference<Thread> atomicReference = new AtomicReference<>();
3
4    public void myLock({
5        Thread thread = Thread.currentThread();
6        System.out.println(thread.getName() + ": come in");
7        while (!atomicReference.compareAndSet(null, thread)) {
8        }
9    }
10
11    public void myUnlock({
12        Thread thread = Thread.currentThread();
13        atomicReference.compareAndSet(thread, null);
14        System.out.println(thread.getName() + ": come out");
15    }
16}

分析一下這段代碼:這個類有一個成員變量,原子引用類型的Thread,關(guān)于原子引用,之前在CAS詳解一文中說到過。這個類還有兩個方法,一個是myLock加鎖方法,一個是myUnlock,釋放鎖的方法。

  • myLock方法:首先獲取到當(dāng)前線程,然后比較并交換,看看當(dāng)前線程是不是null,如果是,就設(shè)置為當(dāng)前線程thread,此時操作結(jié)果就是true,取反后就是false,就不進(jìn)入循環(huán)。如果當(dāng)前線程不是null,那么操作結(jié)果取反后就是true,那么就會進(jìn)入循環(huán),知道thread重新變回null為止。

  • myUnlock方法:獲取到當(dāng)前線程,然后將其設(shè)置為null,這就相當(dāng)于釋放鎖。

用下面的代碼測試一下:

 1public static void main(String[] args) {
2        MyLock myLock = new MyLock();
3        new Thread(() -> {
4            myLock.myLock();
5            try {
6                Thread.sleep(5000);
7            } catch (InterruptedException e) {
8                e.printStackTrace();
9            }
10            myLock.myUnlock();
11        },"A").start();
12
13        try {
14            TimeUnit.SECONDS.sleep(1);
15        } catch (InterruptedException e) {
16            e.printStackTrace();
17        }
18        new Thread(() -> {
19            myLock.myLock();
20            myLock.myUnlock();
21        },"B").start();
22}

A線程進(jìn)去,發(fā)現(xiàn)當(dāng)前是thread是null,所以就將當(dāng)前線程指向自己。此時的當(dāng)前線程就是A,然后小睡5秒。在睡的過程中,B進(jìn)來了,發(fā)現(xiàn)當(dāng)前線程是A,所以進(jìn)入while循環(huán),一直進(jìn)行compareAndSet。5秒中后,A線程釋放鎖,將當(dāng)前線程設(shè)置為了null,這時B發(fā)現(xiàn)當(dāng)前線程是null了,就將當(dāng)前線程設(shè)置為了B,最后B也釋放鎖,將當(dāng)前線程設(shè)置為null。如果把線程A的myUnlock方法注釋掉,那么線程B將一直在while循環(huán)中出不來,造成死循環(huán)。

獨占鎖和共享鎖

1、什么是獨占鎖?什么是共享鎖?

  • 獨占鎖:不管是讀操作還是寫操作,該鎖一次只能被一個線程持有。synchronized和ReentrantLock都是獨占鎖。

  • 共享鎖:指該鎖可以被多個線程持有。

  • ReentrantReadWriteLock的讀鎖是共享鎖,寫鎖是獨占鎖。這樣可以保證讀操作的并發(fā)性。讀&讀可以共享鎖,讀&寫不能共存,寫&寫也不能共存。

下面看一段代碼:

 1public class MyCache {
2    private volatile Map<String, Object> map = new HashMap<>();
3
4    public void put(String key, Object value){
5        System.out.println(Thread.currentThread().getName() + ": 正在寫入: "value );
6        map.put(key, value);
7        System.out.println(Thread.currentThread().getName() + ":寫入完成");
8    }
9
10    public void get(String key){
11        System.out.println(Thread.currentThread().getName() + ": 正在讀取");
12        Object result = map.get(key);
13        System.out.println(Thread.currentThread().getName() + ": 讀取完成: " + result);
14    }
15}

這段代碼就是模擬一個緩存,用HashMap存數(shù)據(jù)?,F(xiàn)在創(chuàng)建5個線程去寫,5個線程去讀,看看情況如何。

 1public static void main(String[] args){
2        MyCache myCache = new MyCache();
3        for (int i=0; i<5; i++){
4            final Integer temp = i;
5            new Thread(() -> myCache.put(temp+"", temp),temp +"號線程").start();
6        }
7
8        for (int i=0; i<5; i++){
9            final Integer temp = i;
10            new Thread(() -> myCache.get(temp+""),temp +"號線程").start();
11        }
12}

看運行結(jié)果:

運行結(jié)果


可以看到,0號線程還沒寫入完成,2號線程進(jìn)來了,2號線程還沒完成,3號線程又進(jìn)來了。這就沒有保證寫操作是獨占的,沒有保證寫操作的原子性??纯词褂肦eentrantReadWriteLock如何解決:

 1public class MyCache {
2    private volatile Map<String, Object> map = new HashMap<>();
3    ReentrantReadWriteLock lock = new ReentrantReadWriteLock();
4    public void put(String key, Object value){
5        lock.writeLock().lock();
6        System.out.println(Thread.currentThread().getName() + ": 正在寫入: "value );
7        map.put(key, value);
8        System.out.println(Thread.currentThread().getName() + ":寫入完成");
9        lock.writeLock().unlock();
10    }
11
12    public void get(String key){
13        lock.readLock().lock();
14        System.out.println(Thread.currentThread().getName() + ": 正在讀取");
15        Object result = map.get(key);
16        System.out.println(Thread.currentThread().getName() + ": 讀取完成: " + result);
17        lock.readLock().unlock();
18    }
19}

只需要在寫操作那里加寫鎖,在讀操作那里加讀鎖,這樣既可以保證數(shù)據(jù)的正確性,也提高了并發(fā)能力。看運行結(jié)果:

運行結(jié)果


可以看到,寫操作的時候,保證了每次寫操作的原子性,是獨占鎖;讀的時候可以多個線程同時訪問,是共享鎖。

說起鎖,好像有很多很多種,其實無外乎synchronized、ReentrantLock、ReentrantReadWriteLock和 自旋鎖。其他的都是從不同角度對這幾種鎖進(jìn)行分類而已。

  • synchronized: 是非公平鎖、可重入鎖、獨占鎖;

  • ReentrantLock:默認(rèn)非公平鎖,在構(gòu)造方法中可傳入true變成公平鎖;是可重入鎖,也是獨占鎖;

  • ReentrantReadWriteLock:讀鎖是共享鎖,寫鎖是獨占鎖;

  • 自旋鎖:通過CAS實現(xiàn)的一種鎖。

END

本站僅提供存儲服務(wù),所有內(nèi)容均由用戶發(fā)布,如發(fā)現(xiàn)有害或侵權(quán)內(nèi)容,請點擊舉報
打開APP,閱讀全文并永久保存 查看更多類似文章
猜你喜歡
類似文章
Java并發(fā)編程:Lock
Synchronized和Lock的區(qū)別
Java并發(fā)入門原理教程(六)
并發(fā)編程之Lock與synchronized
Java鎖的種類以及辨析(四):可重入鎖 | 并發(fā)編程網(wǎng)
Java并發(fā)編程深入學(xué)習(xí)
更多類似文章 >>
生活服務(wù)
分享 收藏 導(dǎo)長圖 關(guān)注 下載文章
綁定賬號成功
后續(xù)可登錄賬號暢享VIP特權(quán)!
如果VIP功能使用有故障,
可點擊這里聯(lián)系客服!

聯(lián)系客服