Java線程的原因死鎖

Question

我是想實現一些基本的啓動，停止，暫停和恢復功能，可以讓我下面的狀態轉換：

• 停止運行
• 運行到停止
• 運行以暫停
• 暫停運行
• 停下來，停止（原因死鎖）

大多數情況下按預期運行，但最後的狀態轉換不可行，因爲它會使線程凍結。有人能解釋我爲什麼會發生這種情況，以及如何預防這種情況？下面是代碼的相關部分：

public class ThreadTest implements Runnable { 

    private volatile boolean running = false; 
    private volatile boolean paused = false; 
    private Thread thread; 

    public ThreadTest() { 
     thread = new Thread(this); 
    } 

    public void run() { 
     while (running) { 
      try { 
       if (paused) { 
        synchronized (this) { 
         while (paused) 
         wait(); 
        } 
       } 
      } 
      catch (InterruptedException e) { 
      } 
     } 
    } 

    public synchronized void start() { 
     if(running && !thread.isAlive()) 
      return; 
     running = true; 
     thread = new Thread(this); 
     thread.start(); 
    } 

    public synchronized void stop() { 
     if(!running && thread.isAlive()) 
      return; 
     running = false; 
     try { 
      thread.join(); 
     } catch (InterruptedException e) { 
      e.printStackTrace(); 
     } 
     System.exit(0);  
    } 

    public synchronized void resume() { 
     if(paused) { 
     paused = false; 
     notify(); 
     } 
     else { 
      return; 
     } 
    } 

    public synchronized void pause() { 
     if(!paused) { 
      paused = true; 
      } 
      else { 
       return; 
      } 
     } 

} 

Answer 1

wait();在run方法將一直等待監守這些不notify(); 當通話停止，線程運行監守永遠等下去，所以thread.join()將鎖定。 你需要停止來電通知或更改等待有史以來wait(1000);

Answer 2

1. 在stop方法，調用只是後thread.notify();running = false;。 （這將通知等待的線程）。

2. 然後你必須設置paused = false;就在你的通知電話之前。

3. 從您的run方法中刪除if (paused)塊。

4. 將您的while (paused)環路更改爲while (paused && running)。或者，您可以使用while (paused) { wait(); if (!running) break;}，具體取決於您想要的控制流程。

5. 良好的措施，所述volatile關鍵字添加到paused和running變量聲明（以創建跨線程存儲器柵欄）。

Answer 3

讓我們看看究竟發生在這裏： 讓我們的名字在這裏參與爲T2和T1（其中調用啓動，在停止方法（您明確實例化，並在你的代碼開始的線程）的線程T2線程對象）。 T1可能是您的主線程，取決於您的其他未顯示的代碼。

你得到一個死鎖，因爲下面的事件序列： （注1：這只是一個可能的序列，有可能在這個代碼其他可能的序列，這也可能導致死鎖）

說我們的ThreadTest對象上做一個start（），暫停（），然後一個stop（）如下（假設在main（））：

ThreadTest t = new ThreadTest(); 
t.start(); 
t.pause(); 
t.stop(); 

1. 暫停過後（）執行T1， T2獲得了鎖定通過在「if（paused）」條件中輸入「synchronized（this）」塊來獲得ThreadTest對象。 （注2：「此」在這裏是指不將T2線程對象，但它是指ThreadTest對象的run（）是在ThreadTest類的方法。）

2. T2進入等待（）並在它進入wait（）調用時釋放ThreadTest對象鎖（隱式地）。

3. 當T1進入stop（）時，由於stop（）是一個同步方法，所以它獲取ThreadTest對象的鎖定。在stop（）中，T1調用t2.join（），並等待T2完成。 但T2已經處於等待狀態（），並且沒有人將其喚醒！

因此死鎖！即使我們通過在wait（）調用中指定超時或通過調用notify（）（如其他人所建議的）來喚醒T2，它仍然無法退出等待狀態，因爲它無法重新啓動，獲取（隱式地）鎖定（在ThreadTest對象上），因爲T1已經在join（）中等待T1了！

一個可能的解決方案： 雖然可能有很多可能的解決方案，你可以試試這個嗎？

在stop（）方法，而不是

thread.join(); 

你可以使用：

if (!paused) { 
    thread.join(); 
} else { 
    thread.interrupt(); 
}