关于线程间通信结合一点业务问题

关于线程间通信问题

问题描述：

    ​老师，我有个问题，如果增加一个业务场景，两个线程同时启动，但是生产和消费都是随机的，即使用(int)(Math.random()*10)决定，而消费需务必保证存货量足够才能进行消费，否则需要先生产足够再进行消费；而生产只受限于每一次生产的数量，那么，如何能保证，调用消费时自检，成功继续；否则消费堵塞，唤醒生产呢？

相关代码：

public class Queue {

    private int n;
    private boolean flag = false;

    public Queue(int n){
        this.n = n;
    }

    public synchronized void getN() {
        int i = (int)(Math.random()*10);
        if(!flag){
            try {
                wait();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        if(this.n-i<0){
            System.out.println("目前为"+this.n+"，生产不够，请先生产");
            flag=!flag;
        }
        this.n -= i;
        System.out.println("消费完还剩余"+this.n);
        flag=!flag;
        notifyAll();
    }


    public synchronized void setN() {
        if(flag){
            try {
                wait();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        int i = (int)(Math.random()*10);
        this.n+=i;
        System.out.println("生产完还剩余"+this.n);
        flag=!flag;
        notifyAll();
    }
}

​public class Productor implements Runnable{

    Queue queue;

    public Productor(Queue queue){
        this.queue = queue;
    }

    @Override
    public void run() {
        while (true){
            queue.setN();
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}

public class Consumer implements Runnable {

    Queue queue;

    public Consumer(Queue queue){
        this.queue = queue;
    }


    @Override
    public void run() {
        while (true){
            queue.getN();
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}