public class ThreadCommunication {
public static Queue<Integer> myQueue = new LinkedList<Integer>();

public static void main(String[] args) {
 ProducerThread pthread = new ProducerThread(myQueue);
 ConsumerThread cthread = new ConsumerThread(myQueue);
 pthread.start();
 cthread.start();
}
}

class ProducerThread extends Thread{
public Queue<Integer> sharedQueue;
public ProducerThread(Queue<Integer> sharedQueue){
 this.sharedQueue = sharedQueue;
}
public void run(){
 for(int i=0;i<10;i++){
 synchronized (sharedQueue) {
  try {
  if(sharedQueue.size()>=1){
   sharedQueue.wait();
  }else{
   sharedQueue.add(i);
   System.out.println("Integer "+i+" is Produced");
   sharedQueue.notifyAll();
  }
  } catch (InterruptedException e) {
    e.printStackTrace();
  }
  }
 }
}
}

class ConsumerThread extends Thread{
 public Queue<Integer> sharedQueue;
 public ConsumerThread(Queue<Integer> sharedQueue){
  this.sharedQueue = sharedQueue;
 }

 public void run(){
  synchronized (sharedQueue) {


  while(true){
   try {
   if(sharedQueue.size()==0){
     sharedQueue.wait();
   }else{
    int result = sharedQueue.poll();
    System.out.println("Consumed Item is "+result);
    sharedQueue.notifyAll();
   }

   } catch (InterruptedException e) {
    // TODO Auto-generated catch block
    e.printStackTrace();
   }
   }
  }
 }

}