線程鎖死

等待線程由于喚醒線程所需要的條件 永遠無法成立導致線程一直無法處于RUNNABLE狀態,我們就稱這個線程被鎖死。

雖然死鎖與鎖死表現出來都是線程等待,無法繼續完成任務,但是產生的條件是不同的,即使在不可能產生死鎖的情況下也可能出現鎖死,所以不能使用對付死鎖的辦法來解決鎖死問題。

鎖死包括信號丟失鎖死和嵌套監視器鎖死。

信號丟失鎖死的典型案例是等待線程執行Object.wait()/Condition.await()前沒有對保護條件進行判斷,可能沒有其他的線程更新相應的保護條件涉及的變量使其成立并通知線程,使得線程一直處于等待狀態。

嵌套監視鎖死是嵌套鎖導致線程永遠無法被喚醒,如有等待方法：

public void waitMethod(){
   synchronized( lock1) {
      synchronized( lock2){
         while( 條件 ){
            lock2.wait();
         }
      }
      //....
   }
}

還有喚醒 方法如下:

public void notifyMethod(){
   synchronized( lock1) {
      synchronized( lock2){
         lock2.notifyAll();
      }
   }
}

package com.wkcto.threadactivity.lockdead;

import java.util.Random;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;

/**
 * 演示嵌套監視鎖死
 */
public class Test {
    public static void main(String[] args) {
        //創建線程,調用 putData方法向隊列中存儲數據
        new Thread(new Runnable() {
            @Override
            public void run() {
                int i = 0;
                while ( i-- < 1000){
                    putData("data--" + i);
                    try {
                        Thread.sleep(new Random().nextInt(50));
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
            }
        }).start();

        //創建線程調用getData方法從隊列中取數據
        new Thread(new Runnable() {
            @Override
            public void run() {
                while (true){
                    getData();
                }
            }
        }).start();
        /*
            程序運行后,不管是putData()方法還是getData()方法獲得鎖的順序是相同,不可能產生死鎖
            運行后出現等待的情況,是因為嵌套監視鎖死導致的等待
         */
    }

    //定義阻塞隊列
    private static final BlockingQueue QUEUE = new ArrayBlockingQueue<>(10);

    //定義方法向隊列中添加數據
    public static synchronized void putData(String data){
        //在同步代碼塊(臨界區)中,調用阻塞隊列QUEUE的put()/take()這些阻塞方法,可能會導致嵌套監視鎖死
        try {
            QUEUE.put(data);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

    //定義方法從隊列中取數據
    public static synchronized void getData(){
        try {
            String data = QUEUE.take();
            System.out.println("取出數據: " + data);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}