Java多线程，生产者消费者问题！

package cn.perwu;

//消费者与生产者例子介绍 wait(),notify(),notifyAll()
//wait(),notify(),notifyAll()只能在同步方法或同步控制块中调用

class Disk {
	private int apple; // number=1 有苹果 number=0 无苹果
	private int count;// 计数器，累计生产10个苹果后，结束

	public int getCount() {
		return count;
	}

	public Disk(int apple) {
		this.apple = apple;
	}

	// 消费者调用消费苹果
	public synchronized void takeApple() {
		String name = "(消费者)-- " + Thread.currentThread().getName();
		if (apple == 0) {
			try {
				System.out.println(name + "【无】苹果，等待生产者生产!");
				wait(); // 消费者释放锁，使生产者能够进入addApple()
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
		} else {
			System.out.println(name + "开始吃苹果-花费5秒!");
			try {
				Thread.sleep(5000);
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
			apple--;
			System.out.println(name + "苹果吃完咯,唤醒生产者!");
			notifyAll();
		}
	}

	// 生产者调用生产苹果
	public synchronized void addApple() {
		String name = "--(生产者)--" + Thread.currentThread().getName();
		if (apple == 1) {
			try {
				System.out.println(name + "【有】苹果，等待消费者消费!");
				wait(); // 生产者释放锁，使消费者能够进入takeApple()
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
		} else {
			System.out.println(name + "开始生产苹果-花费3秒!");
			if (count < 10) {
				count++;
			}
			try {
				Thread.sleep(3000);
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
			apple++;
			System.out.println(name + "苹果做好咯,唤醒消费者!");
			System.out.println("      ---- 计数器的值为 ----- " + count);
			notifyAll();
		}
	}

}

class Producer implements Runnable {
	private Disk d;

	public Producer(Disk d) {
		this.d = d;
	}

	public void run() {
		while (d.getCount() < 10) {
			d.addApple();
		}
	}
}

class Consumer implements Runnable {
	private Disk d;

	public Consumer(Disk d) {
		this.d = d;
	}

	public void run() {
		while (d.getCount() < 11) {
			d.takeApple();
		}
	}
}

public class TestPC {
	public static void main(String[] args) {
		Disk d = new Disk(0); // 初始化盘子为0个苹果
		new Thread(new Consumer(d), "Consumer").start(); // 启动消费者线程
		new Thread(new Producer(d), "Producer").start(); // 启动生产者线程
	}
}