生产者消费者问题

/**
 * 生产者线程类
 */
class Producer implements Runnable {

    /** 持有容器 */
    private Can c = null;

    public Producer(Can c) {
        this.c = c;
    }

    @Override
    public void run() {
        while (true) {
            // 生产一个产品
            Production p = new Production();
            System.out.println(p + "被生产了。");
            // 将产品存入容器
            try {
                c.push(p);
                System.out.println(p + "被放入容器。");
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }

}

/**
 * 消费者线程类
 */
class Consumer implements Runnable{

    /** 持有容器 */
    private Can c = null;

    public Consumer(Can c) {
        this.c = c;
    }

    @Override
    public void run() {
        while (true) {    
            // 从容器取出一个产品
            Production p = null;
            try {
                p = c.pop();
                System.out.println(p + "从容器取出。");
                // 消费一个产品
                System.out.println(p + "被毁灭了。");
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }

}

/**
 * 产品的实体类
 */
class Production {
    
    /** 识别No. */
    private int no = 0;

    private static int counter = 0;

    public Production() {
        no = counter++;
    }

    public String toString() {
        return no + "号产品";
    }

}

/**
 * 用栈实现的容器类
 */
class Can {
    /** 栈顶指针 */
    private int pointer = 0;

    /** 内部持有对象的数组 */
    private Production[] productions = {null, null, null, null, null, null};

    /** 压入一个元素 */
    public synchronized void push(Production p) throws InterruptedException {
        while (pointer == 6) {
            wait();
        }
        productions[pointer++] = p;
        notifyAll();
    }

    /** 弹出一个元素 */
    public synchronized Production pop() throws InterruptedException {
        while (pointer == 0) {
            wait();
        }
        Production p = productions[--pointer];
        notifyAll();
        return p;
    }

}