public class Bakery {
    private static int total;//庫(kù)存
    public static void main(String[] args) {
        Producer producer = new Producer();
        for(int i = 0;i < 2;i++){
            new Thread(producer,"面包師傅-"+(i-1)).start();
        }
        Consumer consumer = new Consumer();
        for(int i = 0;i < 10;i++){
            new Thread(consumer,"消費(fèi)者-"+(i-1)).start();
        }
    }
    private static class Producer implements Runnable{
        private int num = 3; //生產(chǎn)者每次生產(chǎn)三個(gè)面包
        @Override
        public void run() {
            try {
                while(true){ //一直生產(chǎn)
                    synchronized (Bakery.class){
                        while((total+num)>100){ //倉(cāng)庫(kù)滿了，生產(chǎn)者等待
                            Bakery.class.wait();
                        }
                        //等待解除
                        total += num;
                        System.out.println(Thread.currentThread().getName()+"生產(chǎn)面包，庫(kù)存："+total);
                        Thread.sleep(500);
                        Bakery.class.notifyAll(); //喚醒生產(chǎn)
                    }
                    Thread.sleep(500);
                }
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
    private static class Consumer implements Runnable{
        private int num = 1; //消費(fèi)者每次消費(fèi)1個(gè)面包
        @Override
        public void run() {
            try {
                while(true){ //一直消費(fèi)
                    synchronized (Bakery.class){
                        while((total-num)<0){ //倉(cāng)庫(kù)空了，消費(fèi)者等待
                            Bakery.class.wait();
                        }
                        //解除消費(fèi)者等待
                        total -= num;
                        System.out.println(Thread.currentThread().getName()+"消費(fèi)面包，庫(kù)存："+total);
                        Thread.sleep(500);
                        Bakery.class.notifyAll(); //喚醒消費(fèi)
                    }
                    Thread.sleep(500);
                }
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}

        BlockingDeque<String> queue = new LinkedBlockingDeque<>();
        queue.put("hello");
        //如果隊(duì)列為空，直接出出隊(duì)列就會(huì)阻塞
        String ret = queue.take();
        System.out.println(ret);

public class MyBlockingQueue {
    //使用數(shù)組實(shí)現(xiàn)一個(gè)循環(huán)隊(duì)列，隊(duì)列里面存放的是線程要執(zhí)行的任務(wù)
    private Runnable[] tasks;
    //隊(duì)列中任務(wù)的數(shù)量，根據(jù)數(shù)量來(lái)判斷是否可以存取
    private int count;
    private int putIndex; //存放任務(wù)位置
    private int takeIndex; //取出任務(wù)位置
    //有參的構(gòu)造方法，表示隊(duì)列容量
    public MyBlockingQueue(int size){
        tasks = new Runnable[size];
    }
    //存任務(wù)
    public void put(Runnable task){
        try {
            synchronized (MyBlockingQueue.class){
                //如果隊(duì)列容量滿了，則存任務(wù)等待
                while(count == tasks.length){
                    MyBlockingQueue.class.wait();
                }
                tasks[putIndex] = task; //將任務(wù)放入數(shù)組
                putIndex = (putIndex+1) % tasks.length; //更新存任務(wù)位置
                count++; //更新存放數(shù)量
                MyBlockingQueue.class.notifyAll(); //喚醒取任務(wù)
            }
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
    //取任務(wù)
    public Runnable take(){
        try {
            synchronized (MyBlockingQueue.class){
                //如果隊(duì)列任務(wù)為空，則取任務(wù)等待
                while(count==0){
                    MyBlockingQueue.class.wait();
                }
                //取任務(wù)
                Runnable task = tasks[takeIndex];
                takeIndex = (takeIndex+1) % tasks.length; //更新取任務(wù)位置
                count--; //更新存放數(shù)量
                MyBlockingQueue.class.notifyAll(); //喚醒存任務(wù)
                return task;
            }
        } catch (InterruptedException e) {
           throw new RuntimeException("存放任務(wù)出錯(cuò)",e);
        }
    }
}