生産者スレッディングの消費者の誤解

Question

ProducerThreadが10までのランダムな値を生成し、ConsumerThreadがQueueの値を消費することを期待します。どこかのプロデューサが値を複数回追加しています。私は、スレッドがロックを解除し、更新を期待していたスレッドにチャンスを与えるよりも、オブジェクトに対して通知を呼び出すときにコンセプトを持っています。

ここにコードは、私の理解を修正してください。

public class ProducerThread extends Thread { 

    Queue<Integer> values; 

    ProducerThread(Queue<Integer> values) { 
     this.values = values; 
    } 

    public void run() { 
     while(true) { 
      synchronized(values) { 
       double totalValues = Math.random()*10; 
       System.out.println("Going to populate total values:" + totalValues); 

       for (int i = 1; i <= totalValues; i++) { 
        values.add(i); 
        System.out.println("Value updated: " + i); 
        try { 
         Thread.sleep(1000); 
        } catch (InterruptedException e) { 
         // TODO Auto-generated catch block 
         e.printStackTrace(); 
        } 
       } 
       values.notify(); 
      } 
     } 
    } 

} 



public class ConsumerThread extends Thread { 
    Queue<Integer> values; 

    ConsumerThread(Queue<Integer> values) { 
     this.values = values; 
    } 

    @Override 
    public void run() { 
     while(true) { 
      synchronized (values) { 

       try { 
        // Consumer Thread waits until values are populated by Producer Thread 
        if(values.isEmpty()) { 
         values.wait(); 
        } 

        Iterator<Integer> iterateValues = values.iterator(); 
        System.out.println("Going to consume values: " + values.size()); 
        while (iterateValues.hasNext()) { 
         Integer removedValue = iterateValues.next(); 
         System.out.println("Value deleted: " + removedValue); 
        } 
        values.clear(); 
       } catch (InterruptedException e) { 
        // TODO Auto-generated catch block 
        e.printStackTrace(); 
       } 
      } 
     } 
    } 
} 


public class Test { 
    public static void main(String[] args) { 
     Queue<Integer> values = new LinkedList<Integer>(); 
     ProducerThread producer = new ProducerThread(values); 
     ConsumerThread consumer = new ConsumerThread(values); 

     consumer.start(); 
     producer.start(); 

    } 
} 

Answer 1

アハ！あなたは恐ろしい競争状態に遭遇しました！

notifyの直後にProducerThreadが返された場合、前記スレッドにはまだロックがあります。 notifyによって起動されたConsumerThreadは、ロックが利用できないことを確認し、利用可能になるまで待機します。 ProducerThreadがロックを断念

次に、それは、（waitから復帰することによって​​ブロックを再入力の仕方によってProducerThreadを、そしてConsumerThread）バックそのロックを取ることConsumerThreadでレースを入力します。これらが勝つ保証はありません。

あなたProducerThreadがより多くを生産する前に消費すべき項目を待つしたい場合は、/そのシナリオのために通知他の待ち時間を考慮する必要があります。

編集：この画像は物事を少しはっきり説明するのに役立ちます。