についてNotify（）

Question

私はスレッドを通過していましたが、同じオブジェクトの待機プールで待機しているスレッドのうちの1つだけに信号を送信するために、notify()メソッドが使用されていると読んでいます。 notifyAll()メソッドはnotify()と同じ方法で動作し、Objectで待機しているすべてのスレッドに信号を送信します。

私は5つのスレッドと1つのメインスレッドを持っているとしたら、最初はメインスレッドが開始し、その後5つの他のスレッドが開始されます。今私は第三のスレッドに通知を送信したい。 notify()を使用してどうすれば可能ですか？ここでは3番目のスレッドのみに通知しますか？お知らせ下さい。

Answer 1

特定のスレッドに通知する場合は、別のオブジェクトのwait()とし、このオブジェクトにnotify()を呼び出します。

Answer 2

ReentrantLockクラスは、オブジェクトごとに複数の待機セットを許可することにより、​​キーワードよりも細かい粒度制御を提供します。

ReentrantLockから複数のConditionsを取得するには、ReentrantLock.newCondition()を使用します。スレッドはCondition.await()（機能はObject.wait()と同様）を呼び出し、別のスレッドがCondition.signal()（機能はObject.notify()と同様）を呼び出すまでブロックします。

ReentrantLockに対して複数のConditionsを作成することができます。したがって、ThreadごとにConditionを作成し、目覚めたいThreadに対応する条件でsignal()を呼び出してください。

---

ここでは、上記を示す簡単なコード例を示します。それは同じの別のすべてを待つ5 Threadsを作成します。ReentrantLock。その後、メインスレッドはsignal()を呼び出して、Threadsの特定の1つを起動します。

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

はスレッド番号3は、目が覚めた

THEAD番号3を目覚めます！