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() {
            //消費者持續(xù)工作
            while (true){
                //加鎖保證安全
                synchronized (queue){
                    //隊列為空
                    if(queue.isEmpty()){
                        System.out.println("當前隊列為空....");
                        try {
                            //等待
                            queue.wait();
                        } catch (InterruptedException e) {
                            e.printStackTrace();
                            //出現(xiàn)異常手動喚醒
                            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();
        }
    }
}