package pinx.thread;

 import java.util.LinkedList;

 import java.util.Queue;

 public class ProducerConsumer {

     Storage storage=null;

     Query query=null;

     public ProducerConsumer(int max){

         storage=new Storage(max);

         query=new Query();

     }

     public void start(){

         Producter producter=new Producter();

         Consumer consumer=new Consumer();

         Thread thread1=new Thread(producter);

         Thread thread2=new Thread(consumer);

         Thread thread3=new Thread(consumer);

         Thread thread4=new Thread(consumer);

         thread1.start();

         thread2.start();

         thread3.start();

         thread4.start();

     }

     /**

      * @param args

      */

     public static void main(String[] args) {

         ProducerConsumer pc=new ProducerConsumer(20);

         pc.start();

     }

     class Product {

         private int id;

         public Product(int id) {

             this.id = id;

         }

         public String toString() {

             return "Product " + this.id;

         }

     }

     class Query{

         public Query(){}

         public synchronized int get(){

             return -1;

         }

     }

     class Storage {

         Queue<Product> queue = null;

         int max = 0;

         public Storage(int max) {

             this.max = max;

             this.queue = new LinkedList<Product>();

         }

         public synchronized void push(Product product) {

             while (this.max == this.queue.size()) {

                 try {

                     this.wait();

                 } catch (InterruptedException e) {

                     e.printStackTrace();

                 }

             }

             this.queue.offer(product);

             System.out.println("Producter has generated a product :"

                     + product.toString());

             this.notifyAll();

         }

         public synchronized Product pop() {

             while (this.queue.isEmpty()) {

                 try {

                     this.wait();

                 } catch (InterruptedException e) {

                     e.printStackTrace();

                 }

             }

             Product product = this.queue.poll();

             System.out.println("Consumer has consumed a product :"

                     + product.toString()+" ~~~");

             return product;

         }

     }

     class Consumer implements Runnable {

         public void run() {

             while(true){

                 System.out.println(String.format("Producter get the query value : %d", query.get()));

                 storage.pop();

                 try {

                     Thread.sleep((int)(Math.random()*1000));

                 } catch (InterruptedException e) {

                     e.printStackTrace();

                 }

             }

         }

     }

     class Producter implements Runnable {

         public void run() {

             int index=0;

             while(true){

                 System.out.println(String.format("Producter get the query value : %d~~~~~~~~~~~~~~~~~~~", query.get()));

                 storage.push(new Product(++index));

                 try {

                     Thread.sleep((int)(Math.random()*1000));

                 } catch (InterruptedException e) {

                     e.printStackTrace();

                 }

             }

         }

     }

 }