スレッドnotifyAll（）

Question

スレッドには複数の状態があります。実行中の実行可能な実行中の待機中であり、終了しました。 notifyAll（）メソッドは、オブジェクトのロック上に「待機中」のすべてのスレッドを「実行可能」状態に戻し、次の実行オブジェクトとして選択することが想定されています。 次の例では、 'calc'オブジェクトのロックが解除されるまで待機（wait（）メソッド）する3つのReaderスレッドをインスタンス化して開始します。 calcオブジェクトスレッドはインスタンス化され、この後すぐにいくつかの数値を加算し、その後にnotifyAll（）を追加します。

私の質問は、calcスレッドが毎回すべてのリーダースレッドに通知するのはなぜですか？私はこれを私のコンピュータ上で実行すると、ヒットしてミスします。複数のスレッドを実行する際、スレッドの実行順序をが保証されない

public class Reader extends Thread{ 
    Calculator c; 

    public Reader(Calculator calc){ 
     c=calc; 
    } 

    public void run(){ 
     synchronized(c){ 
      try{ 
       System.out.println("Waiting for calculation..."); 
       c.wait(); 
      }catch(InterruptedException e){} 
      System.out.println("Total is: "+c.total); 
     } 
    } 
    public static void main(String[] args){ 
     Calculator calc = new Calculator(); 
     new Reader(calc).start(); 
     new Reader(calc).start(); 
     new Reader(calc).start(); 
     new Thread(calc).start(); 
    } 
} 
class Calculator implements Runnable{ 
    int total; 

    public void run(){ 
     synchronized(this){ 
      for(int i =0; i<100; i++){ 
       total+=i; 
      } 
      notifyAll(); 
     } 
    } 
} 

Answer 1

。

Calculatorスレッドがループを完了してnotifyAll()のスレッドが実行可能な状態になる前に呼び出している可能性があります。したがって、すべてReaderは待機し続け、決してtotalを印刷しません。

このような状況を回避するには、別のフラグisCalculatedをCalculatorに使用し、計算が完了したらこのフラグを設定します。 Readerスレッドはまた、このフラグをチェックし、isCalculatedがfalseの場合にのみ待機します。あなたが待機を呼び出す前に、いくつかのフラグをチェックすることができ@Sudhirで述べたように

class Reader extends Thread { 
    Calculator c; 

    public Reader(Calculator calc) { 
    c = calc; 
    } 

    public void run() { 
    synchronized (c) { 
     try { 
     System.out.println("Waiting for calculation..."); 

     if (!c.isCalculated) { // wait only if calculation is not done 
      c.wait(); 
     } 
     } catch (InterruptedException e) { 
     } 
     System.out.println("Total is: " + c.total); 
    } 
    } 
} 

class Calculator implements Runnable { 
    int total; 
    boolean isCalculated; 

    public void run() { 
    synchronized (this) { 
     for (int i = 0; i < 100; i++) { 
     total += i; 
     } 

     isCalculated = true; // set flag to mark that computation is complete 
     notifyAll(); 
    } 
    } 
} 

Answer 2

、 チェックはこのチュートリアル：待ち時間が呼び出される前に、あなたのケースのnotifyAll（にhttp://docs.oracle.com/javase/tutorial/essential/concurrency/guardmeth.html

が）と呼ばれてもよい。..ので、スレッドがよいです通知が呼び出されるのを待つことを続ける