[multi threading exercise] write a multi threading example of the producer consumer model.

  Write a producer - Multithreading example of consumer mode .

（ Maintain a balance between production and consumption resources ）

public class Test {
    private int count;// requirement count Stay in 10
    public synchronized void add(){
        // Producer thread  , When count>10, Let the producer thread wait , Wake up consumer thread 
        while (count>10){
            try {
                this.wait();// wait for , The following code can only be executed after being awakened 
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        count++;
        this.notifyAll();
        System.out.println(" Produced a commodity , Inventory surplus ："+count);
    }
    public synchronized void sub(){
        // Consumer thread  , When count<10, Let the consumer thread wait , Wake up the producer thread 
        while (count<10){
            try {
                this.wait();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        count--;
        this.notifyAll();
        System.out.println(" Sold a commodity , Inventory surplus ："+count);
    }

    public static void main(String[] args) {
        Test t=new Test();
        ProductRunnable pr=new ProductRunnable(t);
        ConsummerRunnable cr=new ConsummerRunnable(t);
        new Thread(pr).start();
        new Thread(pr).start();
        new Thread(pr).start();
        new Thread(pr).start();
        new Thread(cr).start();
        new Thread(cr).start();
        new Thread(cr).start();
        new Thread(cr).start();
        new Thread(cr).start();
        new Thread(cr).start();

    }

    private static class ProductRunnable implements Runnable{
        private Test t;
        public ProductRunnable(Test t){
            this.t = t;
        }
        public void run(){// Thread method 
            while(true){
                t.add();// Add goods to the warehouse 
                try {
                    Thread.sleep(1000);// Set thread rest 1s
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
        }

    }

    private static class ConsummerRunnable implements Runnable{
        private Test t;
        public ConsummerRunnable(Test t){
            this.t = t;
        }
        public void run(){
            while(true){
                t.sub();
                try {
                    Thread.sleep(1000);
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
        }
    }
}

Running results ：