国产探花免费观看_亚洲丰满少妇自慰呻吟_97日韩有码在线_资源在线日韩欧美_一区二区精品毛片,辰东完美世界有声小说,欢乐颂第一季,yy玄幻小说排行榜完本

首頁 > 編程 > Java > 正文

java多線程學習之死鎖的模擬和避免

2019-11-06 08:07:45
字體:
來源:轉載
供稿:網友

1.死鎖

死鎖是這樣一種情形:多個線程同時被阻塞,它們中的一個或者全部都在等待某個資源被釋放。由于線程被無限期地阻塞,因此程序不可能正常終止。java 死鎖產生的四個必要條件:    1、互斥使用,即當資源被一個線程使用(占有)時,別的線程不能使用    2、不可搶占,資源請求者不能強制從資源占有者手中奪取資源,資源只能由資源占有者主動釋放。    3、請求和保持,即當資源請求者在請求其他的資源的同時保持對原有資源的占有。    4、循環等待,即存在一個等待隊列:P1占有P2的資源,P2占有P3的資源,P3占有P1的資源。這樣就形成了一個等待環路。當上述四個條件都成立的時候,便形成死鎖。當然,死鎖的情況下如果打破上述任何一個條件,便可讓死鎖消失。

2.模擬一個死鎖

package com.tl.skyLine.thread;import java.util.Date;/** * Created by tl on 17/3/3. */public class DeadLock {    public static String bowl = "碗";    public static String chopsticks = "筷子";    public static void main(String[] args) {        LockA la = new LockA();        new Thread(la).start();        LockB lb = new LockB();        new Thread(lb).start();    }}class LockA implements Runnable {    public void run() {        try {            System.out.PRintln(new Date().toString() + "鄒保健開始拿餐具吃飯");            while (true) {                synchronized (DeadLock.bowl) {                    System.out.println(new Date().toString() + "鄒保健搶到了碗");                    Thread.sleep(3000); // 此處等待是給B能鎖住機會                    synchronized (DeadLock.chopsticks) {                        System.out.println(new Date().toString() + "鄒保健搶到了筷子");                        Thread.sleep(60 * 1000); // 為測試,占用了就不放                    }                }            }        } catch (Exception e) {            e.printStackTrace();        }    }}class LockB implements Runnable {    public void run() {        try {            System.out.println(new Date().toString() + "陳頂天開始拿餐具吃飯");            while (true) {                synchronized (DeadLock.chopsticks) {                    System.out.println(new Date().toString() + "陳頂天搶到了筷子");                    Thread.sleep(3000); // 此處等待是給A能鎖住機會                    synchronized (DeadLock.bowl) {                        System.out.println(new Date().toString() + "陳頂天搶到了碗");                        Thread.sleep(60 * 1000); // 為測試,占用了就不放                    }                }            }        } catch (Exception e) {            e.printStackTrace();        }    }}結果:

Fri Mar 03 16:34:36 CST 2017陳頂天開始拿餐具吃飯Fri Mar 03 16:34:37 CST 2017陳頂天搶到了筷子Fri Mar 03 16:34:36 CST 2017鄒保健開始拿餐具吃飯Fri Mar 03 16:34:37 CST 2017鄒保健搶到了碗

結果陳頂天同學搶到了參筷子,拿著不放,鄒保健同學搶到了碗,也死活不放手,但是只有一雙筷子和一雙碗,結果就是雙雙餓死。。。

3.避免死鎖

假如我們是陳頂天和鄒保健同學的同事,肯定不忍心看到他們餓死,那么怎么辦呢?

為了解決這個問題,我們不使用顯示的去鎖,我們用信號量Semaphore去控制。信號量可以控制資源能被多少線程訪問,這里我們指定只能被一個線程訪問,就做到了類似鎖住。而信號量可以指定去獲取的超時時間,我們可以根據這個超時時間,去做一個額外處理。對于無法成功獲取的情況,一般就是重復嘗試,或指定嘗試的次數,也可以馬上退出。

package com.tl.skyLine.thread;import java.util.Date;import java.util.concurrent.Semaphore;import java.util.concurrent.TimeUnit;/** * Created by tl on 17/3/3. */public class UnDeadLock {    public static String bowl = "碗";    //信號量可以碗只能能被一個線程同時訪問    public static final Semaphore a1 = new Semaphore(1);    public static String chopsticks = "筷子";    //信號量可以筷子只能能被一個線程同時訪問    public static final Semaphore a2 = new Semaphore(1);    public static void main(String[] args) {        LockAa la = new LockAa();        new Thread(la).start();        LockBa lb = new LockBa();        new Thread(lb).start();    }}class LockAa implements Runnable {    public void run() {        try {            System.out.println(new Date().toString() + "鄒保健開始拿餐具吃飯");            while (true) {                if (UnDeadLock.a1.tryAcquire(1, TimeUnit.SECONDS)) {                    System.out.println(new Date().toString() + "鄒保健搶到了碗");                    if (UnDeadLock.a2.tryAcquire(1, TimeUnit.SECONDS)) {                        System.out.println(new Date().toString() + "鄒保健搶到了筷子,湊齊了餐具,準備吃飯");                        Thread.sleep(60 * 1000 * 10); // 搶到餐具就開始吃飯,吃飯時間十分鐘                    } else {                        System.out.println(new Date().toString() + "筷子已經被搶走了,鄒保健搶筷子失敗");                    }                } else {                    System.out.println(new Date().toString() + "碗已經被搶走了,鄒保健搶碗失敗");                }                UnDeadLock.a1.release(); // 釋放                UnDeadLock.a2.release();                System.out.println(new Date().toString() + "鄒保健把搶到的部分餐具又放回原處");                Thread.sleep(1000); // 馬上進行嘗試,現實情況下do something是不確定的            }        } catch (Exception e) {            e.printStackTrace();        }    }}class LockBa implements Runnable {    public void run() {        try {            System.out.println(new Date().toString() + "陳頂天開始拿餐具吃飯");            while (true) {                if (UnDeadLock.a2.tryAcquire(1, TimeUnit.SECONDS)) {                    System.out.println(new Date().toString() + "陳頂天搶到了筷子");                    if (UnDeadLock.a1.tryAcquire(1, TimeUnit.SECONDS)) {                        System.out.println(new Date().toString() + "陳頂天搶到了碗,湊齊了餐具,準備吃飯");                        Thread.sleep(60 * 1000 * 10); // 搶到餐具就開始吃飯,吃飯時間十分鐘                    } else {                        System.out.println(new Date().toString() + "碗已經被搶走了,陳頂天搶碗失敗");                    }                } else {                    System.out.println(new Date().toString() + "筷子已經被搶走了,陳頂天搶筷子失敗");                }                UnDeadLock.a1.release(); // 釋放                UnDeadLock.a2.release();                System.out.println(new Date().toString() + "陳頂天把搶到的部分餐具又放回原處");                Thread.sleep(10 * 1000);//這里只是為了演示,所以tryAcquire只用1秒,而且B要給A讓出能執行的時間,否則兩個永遠是死鎖            }        } catch (Exception e) {            e.printStackTrace();        }    }}結果:

Fri Mar 03 18:12:07 CST 2017鄒保健開始拿餐具吃飯Fri Mar 03 18:12:07 CST 2017陳頂天開始拿餐具吃飯Fri Mar 03 18:12:07 CST 2017鄒保健搶到了碗Fri Mar 03 18:12:07 CST 2017陳頂天搶到了筷子Fri Mar 03 18:12:08 CST 2017筷子已經被搶走了,鄒保健搶筷子失敗Fri Mar 03 18:12:08 CST 2017鄒保健把搶到的部分餐具又放回原處Fri Mar 03 18:12:08 CST 2017陳頂天搶到了碗,湊齊了餐具,準備吃飯Fri Mar 03 18:12:10 CST 2017碗已經被搶走了,鄒保健搶碗失敗Fri Mar 03 18:12:10 CST 2017鄒保健把搶到的部分餐具又放回原處Fri Mar 03 18:12:11 CST 2017鄒保健搶到了碗Fri Mar 03 18:12:11 CST 2017鄒保健搶到了筷子,湊齊了餐具,準備吃飯很明顯看到,我們打破了滿足死鎖的第三條,即當資源請求者在請求其他的資源的同時保持對原有資源的占有,當沒有完全搶到碗和筷子的時候,兩個人(線程)全部釋放占有的資源,重新開始爭搶資源,這樣一個人搶到碗和筷子之后,吃飽再給另一個吃,這樣你就成功了拯救了你的兩位同事!

Semaphore api:

acquirepublic void acquire()             throws InterruptedException    從此信號量獲取一個許可,在提供一個許可前一直將線程阻塞,否則線程被中斷。獲取一個許可(如果提供了一個)并立即返回,將可用的許可數減 1。    如果沒有可用的許可,則在發生以下兩種情況之一前,禁止將當前線程用于線程安排目的并使其處于休眠狀態:        某些其他線程調用此信號量的 release() 方法,并且當前線程是下一個要被分配許可的線程;或者        其他某些線程中斷當前線程。    如果當前線程:        被此方法將其已中斷狀態設置為 on ;或者        在等待許可時被中斷。    則拋出 InterruptedException,并且清除當前線程的已中斷狀態。     拋出:        InterruptedException - 如果當前線程被中斷releasepublic void release()    釋放一個許可,將其返回給信號量。釋放一個許可,將可用的許可數增加 1。如果任意線程試圖獲取許可,則選中一個線程并將剛剛釋放的許可給予它。然后針對線程安排目的啟用(或再啟用)該線程。    不要求釋放許可的線程必須通過調用 acquire() 來獲取許可。通過應用程序中的編程約定來建立信號量的正確用法。wait()與sleep()的區別:

sleep()方法只讓出了CPU,而并不會釋放同步資源鎖!!!wait()方法則是指當前線程讓自己暫時退讓出同步資源鎖,以便其他正在等待該資源的線程得到該資源進而運行;


發表評論 共有條評論
用戶名: 密碼:
驗證碼: 匿名發表
主站蜘蛛池模板: 伊川县| 通河县| 凤凰县| 濮阳县| 随州市| 河源市| 神木县| 平塘县| 邯郸县| 海门市| 大姚县| 株洲县| 崇明县| 乃东县| 嘉善县| 嘉峪关市| 安阳县| 涡阳县| 福泉市| 观塘区| 黑河市| 肥城市| 富顺县| 茂名市| 新津县| 广德县| 洪雅县| 武陟县| 娱乐| 江达县| 平果县| 虹口区| 龙川县| 察雅县| 基隆市| 天津市| 蒙自县| 凤翔县| 马尔康县| 克什克腾旗| 岑溪市|