方式一：
/**
 * 使用非阻塞佇列PriorityQueue及wait/notify方法實現一個阻塞佇列
*
*/
class MyBlockingQueue {
    public final static int queueSize = 10;
    public static final PriorityQueue<Integer> queue = new PriorityQueue();
}
    
class Producer extends Thread {
    public void run() {
        while(true) {
            synchronized(MyBlockingQueue.queue) {
                while(MyBlockingQueue.queue.size() == MyBlockingQueue.queueSize) {
                    try {
                        System.out.println("烤豬數量已滿，快來吃吧：" + MyBlockingQueue.queue.size());
                        MyBlockingQueue.queue.wait();
                    } catch(InterruptedException e) {
                        e.printStackTrace();
                        notify();
                    }
                        
                }
                MyBlockingQueue.queue.offer(1);
                System.out.println("我烤了一頭豬，烤豬數量："+MyBlockingQueue.queue.size());
                MyBlockingQueue.queue.notify();
            }
        }
    }
}
class Consumer extends Thread {
    public void run() {
        while(true) {
            synchronized(MyBlockingQueue.queue) {
                while(MyBlockingQueue.queue.size() == 0) {
                    try {
                        System.out.println("沒有烤乳豬了，趕快生產一個：" + MyBlockingQueue.queue.size());
                        MyBlockingQueue.queue.wait();
                    } catch(InterruptedException e) {
                        e.printStackTrace();
                        notify();
                    }
                        
                }
                MyBlockingQueue.queue.poll();
                System.out.println("吃掉了一頭烤乳豬，當前烤乳豬數量："+MyBlockingQueue.queue.size());
                MyBlockingQueue.queue.notify();
            }
        }
    }
}

方式二：
/**
* 使用阻塞佇列ArrayBlockingQueue實現生產者消費者問題
 *
*/
class MyBlockingQueue {
    public final static int queueSize = 10;
    public static ArrayBlockingQueue<Integer> queue = new ArrayBlockingQueue(queueSize);
        
}
    
class Producer extends Thread {
    public void run() {
        while(true) {
            try {
                MyBlockingQueue.queue.put(1);
                System.out.println("生產了一頭烤乳豬，當前乳豬數量：" + MyBlockingQueue.queue.size());
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}
class Consumer extends Thread {
    public void run() {
        while(true) {
            try {
                MyBlockingQueue.queue.take();
                System.out.println("吃了一頭烤乳豬，當前乳豬數量：" + MyBlockingQueue.queue.size());
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}