關於通知（）

Question

我正在瀏覽線程，並且我讀到notify()方法用於向同一對象的等待池中正在等待的線程中的一個且僅有一個線程發送信號。方法notifyAll()的工作方式與notify()相同，只是它將信號發送給所有等待Object的線程。

現在我的問題是，假設我有5個線程和一個主線程，所以最初主線程啓動，然後另外5個線程啓動。現在我想只發送通知給第三個線程。使用notify()怎麼可能，因爲在這裏我只向第三個線程發送通知？請指教。

Answer 1

如果您想要通知特定線程，請將其wait()放在不同的對象上，並且在該對象上調用notify()。

Answer 2

ReentrantLock類爲您提供比​​關鍵字更多的細粒度控制，允許每個對象有多個等待設置。

您可以使用ReentrantLock.newCondition()從ReentrantLock獲得多個Conditions。線程然後可以調用Condition.await()（功能類似於Object.wait()）並且將阻塞，直到另一個線程調用Condition.signal()（在功能上類似於Object.notify()）。

區別在於您可以爲單個ReentrantLock創建多個Conditions。因此，您可以爲每個Thread創建一個Condition，並根據您想要喚醒的Thread對應的條件呼叫signal()。

---

下面是一個簡單的示例代碼，它演示了上述情況。它創建了5個Threads，它們都在等同於ReentrantLock的不同Conditions。主線程然後調用signal()來喚醒Threads中的特定一個。

import java.util.concurrent.locks.Condition; 
import java.util.concurrent.locks.ReentrantLock; 

public class ReentranLockTest 
{ 
    public static void main(String[] args) 
    { 
     final ReentrantLock lock = new ReentrantLock(); 

     int numThreads = 5; 

     Condition[] conditions = new Condition[numThreads]; 

     // start five threads, storing their associated Conditions 
     for (int i = 0; i < numThreads; i++) 
     { 
      final int threadNumber = i; 

      System.out.printf("Started thread number %d%n", threadNumber); 

      // to create a Condition we must lock the associated ReentrantLock 
      lock.lock(); 
      try 
      { 
       final Condition condition = lock.newCondition(); 
       conditions[i] = condition; 

       // start the worker Thread 
       (new Thread() 
       { 
        @Override 
        public void run() 
        { 
         // wait on the Condition 
         // to do so we must be holding the 
         // associated ReentrantLock 
         lock.lock(); 
         try 
         { 
          condition.await(); 
         } 
         catch (InterruptedException e) 
         { 
          e.printStackTrace(); 
         } 
         finally 
         { 
          lock.unlock(); 
         } 

         // print something when signal() 
         // is called on our Condition 
         System.out.printf("Thread number %d woke up!%n", threadNumber); 
        } 
       }).start(); 
      } 
      finally 
      { 
       lock.unlock(); 
      } 
     } 

     // acquire the ReentrantLock and call 
     // Condition.signal() to wake up Thread number 3  
     lock.lock(); 
     try 
     { 
      System.out.printf("Waking up Thead number %d%n", 3); 

      conditions[3].signal(); 
     } 
     finally 
     { 
      lock.unlock(); 
     } 
    } 
} 

這應該打印以下：

發起者線程編號0

發起者線程數1

發起者線程數2

發起者線程數3

開始線程數4

醒來的tHead 3號

螺紋數3醒了！