MultiThreading8.java

/**
 * Created by Admin on 15-04-2017.
 */
public class MultiThreading8 {
    static class Q {
        int n;
        boolean valueSet = false;
        synchronized int get() {
            while(!valueSet)
                try {
                    wait();
                } catch(InterruptedException e) {
                    System.out.println("InterruptedException caught");
                }
            System.out.println("Got: " + n);
            valueSet = false;
            notify();
            return n;
        }
        synchronized void put(int n) {
            while(valueSet)
                try {
                    wait();
                } catch(InterruptedException e) {
                    System.out.println("InterruptedException caught");
                }
            this.n = n;
            valueSet = true;
            System.out.println("Put: " + n);
            notify();
        }
    }
    static class Producer implements Runnable {
        Q q;
        Producer(Q q) {
            this.q = q;
            new Thread(this, "Producer").start();
        }
        public void run() {
            int i = 0;
            while(true) {
                q.put(i++);
            }
        }
    }
    static class Consumer implements Runnable {
        Q q;
        Consumer(Q q) {
            this.q = q;
            new Thread(this, "Consumer").start();
        }
        public void run() {
            while(true) {
                q.get();
            }
        }
    }

    public static void main(String[] args){
        Q q=new Q();
        Producer producer=new Producer(q);
        Consumer consumer=new Consumer(q);
    }
}