title: Regarding producers and consumer pattern in java with blocking queue approach
body: <p>I was doing a research in producers and consumer design patterns with regards to threads in java, I recently explored in java 5 with the introduction With introduction of BlockingQueue Data Structure in Java 5 Its now much simpler because BlockingQueue provides this control implicitly by introducing blocking methods put() and take(). Now you don't require to use wait and notify to communicate between Producer and Consumer. BlockingQueue put() method will block if Queue is full in case of Bounded Queue and take() will block if Queue is empty. In next section we will see a code example of Producer Consumer design pattern. I have developed the below program but please also let me know the old style approach of waut() and notify() , I want to develop the same logic with old style approach also</p>
  
  <p>Folks please advise how this can be implemented in , classical way is using wait() and notify() method to communicate between Producer and Consumer thread and blocking each of them on individual condition like full queue and empty queue...?</p>
  
  <pre><code>    import java.util.concurrent.BlockingQueue;
  import java.util.concurrent.LinkedBlockingQueue;
  import java.util.logging.Level;
  import java.util.logging.Logger;
  
  public class ProducerConsumerPattern {
  
      public static void main(String args[]){
  
       //Creating shared object
       BlockingQueue sharedQueue = new LinkedBlockingQueue();
  
       //Creating Producer and Consumer Thread
       Thread prodThread = new Thread(new Producer(sharedQueue));
       Thread consThread = new Thread(new Consumer(sharedQueue));
  
       //Starting producer and Consumer thread
       prodThread.start();
       consThread.start();
      }
  
  }
  
  //Producer Class in java
  class Producer implements Runnable {
  
      private final BlockingQueue sharedQueue;
  
      public Producer(BlockingQueue sharedQueue) {
          this.sharedQueue = sharedQueue;
      }
  
      @Override
      public void run() {
          for(int i=0; i&lt;10; i++){
              try {
                  System.out.println("Produced: " + i);
                  sharedQueue.put(i);
              } catch (InterruptedException ex) {
                  Logger.getLogger(Producer.class.getName()).log(Level.SEVERE, null, ex);
              }
          }
      }
  
  }
  
  //Consumer Class in Java
  class Consumer implements Runnable{
  
      private final BlockingQueue sharedQueue;
  
      public Consumer (BlockingQueue sharedQueue) {
          this.sharedQueue = sharedQueue;
      }
  
      @Override
      public void run() {
          while(true){
              try {
                  System.out.println("Consumed: "+ sharedQueue.take());
              } catch (InterruptedException ex) {
                  Logger.getLogger(Consumer.class.getName()).log(Level.SEVERE, null, ex);
              }
          }
      }
  
  
  }
  
  Output:
  Produced: 0
  Produced: 1
  Consumed: 0
  Produced: 2
  Consumed: 1
  Produced: 3
  Consumed: 2
  Produced: 4
  Consumed: 3
  Produced: 5
  Consumed: 4
  Produced: 6
  Consumed: 5
  Produced: 7
  Consumed: 6
  Produced: 8
  Consumed: 7
  Produced: 9
  Consumed: 8
  Consumed: 9
  </code></pre>