多线程之偷了个懒之经典生产消费问题

package kkk;

public class Jingdian {
public static void main(String args[]){
Clerk cl=new Clerk();
Thread prt=new Thread(new Producer(cl));//生产者线程
Thread cot=new Thread(new Consumer(cl));//消费者线程
prt.start();
cot.start();
}
}
//新建另一个类
package kkk;

public class Clerk {
private int product=0;//产品默认为0;
public synchronized void addProduct(){//生产者生成出来的产品交给店员
if(this.product>=20){//20个最大库存
try {
wait();//产品已满，请稍等在生产
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}else{
product++;
System.out.println("生产者生产第"+product+"个产品");
notifyAll();//通知等待区的消费者今天取产品了
}
}//消费者从店员处取产品
public synchronized void getProduct(){
if(this.product<=0){
try {
wait();//产品没有货了，请稍等再取
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}else{
System.out.println("消费者取走了第"+product+"个产品");
product--;
notifyAll();//通知等待区的生成者可以生产 产品
}
}

}
//新建消费类
package kkk;
//消费者线程要执行的任务
public class Consumer implements Runnable {
private Clerk cl;
public Consumer(Clerk cl){
this.cl=cl;
}
public void run(){
System.out.println("消费者开始取走产品");
while(true){
try{
Thread.sleep((int)(Math.random()*10)*100);
}catch(InterruptedException e){
e.printStackTrace();
}
cl.getProduct();//取走产品
}
}
}
//新建生产者类
package kkk;
//生产者线程要执行的任务
public class Producer implements Runnable {
private Clerk cl;
public Producer(Clerk cl){
this.cl=cl;
}

public void run(){
System.out.println("生产者开始生产产品!");
while(true){
try {
Thread.sleep((int)(Math.random()*10)*100);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
cl.addProduct();//生产产品
}
}
}