public synchronized void produce(int neednum) {
　　//测试是否需要生产
　　while (neednum + curnum > max_size) {
　　System.out.println("要生产的产品数量" + neednum + "超过剩余库存量" + (max_size - curnum) + "，暂时不能执行生产任务!");
　　try {
　　//当前的生产线程等待
　　wait();
　　} catch (InterruptedException e) {
　　e.printStackTrace();
　　}
　　}
　　//满足生产条件，则进行生产，这里简单的更改当前库存量
　　curnum += neednum;
　　System.out.println("已经生产了" + neednum + "个产品，现仓储量为" + curnum);
　　//唤醒在此对象监视器上等待的所有线程
　　notifyAll();
　　}
　　/**
　　* 消费指定数量的产品
　　*
　　* @param neednum
　　*/
　　public synchronized void consume(int neednum) {
　　//测试是否可消费
　　while (curnum < neednum) {
　　try {
　　//当前的生产线程等待
　　wait();
　　} catch (InterruptedException e) {
　　e.printStackTrace();
　　}
　　}
　　//满足消费条件，则进行消费，这里简单的更改当前库存量
　　curnum -= neednum;
　　System.out.println("已经消费了" + neednum + "个产品，现仓储量为" + curnum);
　　//唤醒在此对象监视器上等待的所有线程
　　notifyAll();
　　}
　　}
　　/**
　　* 生产者
　　*/
　　class Producer extends Thread {
　　private int neednum; //生产产品的数量
　　private Godown godown; //仓库
　　Producer(int neednum, Godown godown) {
　　this.neednum = neednum;
　　this.godown = godown;
　　}