public class MyMq {

    //队列最大长度
    private static final int MAX_LENG = 10;
    //队列
    private ArrayBlockingQueue<Integer> queue = new ArrayBlockingQueue<>(MAX_LENG);
    //生成者
    class Producter extends Thread{
        @Override
        public void run() {
            synchronized (queue){
                if(queue.size()>MAX_LENG){
                    try {
                        //最大长度 生产者等待
                        queue.wait();
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                        System.out.println("当前队列已满....");
                        queue.notify();
                    }
                }else {
                    //生产消息
                    queue.add(queue.size()+1);
                    System.out.println("往队列里添加一条消息....");
                    queue.notify();
                    //为了测试睡眠1秒
                    try {
                        Thread.sleep(1000);
                    } catch (InterruptedException e) {
                        throw new RuntimeException(e);
                    }
                }
            }
        }
    }

    //消费者
    class Consumer extends Thread{
        @Override
        public void run() {
            //消费者持续工作
            while (true){
                //加锁保证安全
                synchronized (queue){
                    //队列为空
                    if(queue.isEmpty()){
                        System.out.println("当前队列为空....");
                        try {
                            //等待
                            queue.wait();
                        } catch (InterruptedException e) {
                            e.printStackTrace();
                            //出现异常手动唤醒
                            queue.notify();
                        }
                    }else {
                        //消费者消费
                        System.out.println("消费者开始消费...");
                        queue.poll();
                        //唤醒生产者
                        queue.notify();
                    }
                }
            }
        }
    }

    public static void main(String[] args) {
        MyMq mq = new MyMq();
        Consumer consumer = mq.new Consumer();
        consumer.start();

        for (int i = 0; i < 10; i++) {
            Producter producter = mq.new Producter();
            producter.start();
        }
    }
}