java多线程解决生产者消费者问题

/*
*生产者和消费者案例
*/
publicclassTestProductorAndConsumer{

publicstaticvoidmain(String[]args){
Clerkclerk=newClerk();

Productorpro=newProductor(clerk);
Consumercus=newConsumer(clerk);

newThread(pro,"生产者A").start();
newThread(cus,"消费者B").start();
}

}

//店员
classClerk{
privateintproduct=0;

//进货
publicsynchronizedvoidget(){//循环次数：0
while(product>=1){//为了避免虚假唤醒问题，应该总是使用在循环中
System.out.println("产品已满！");

try{
this.wait();
}catch(InterruptedExceptione){
}

}

System.out.println(Thread.currentThread().getName()+":"+++product);
this.notifyAll();
}

//卖货
publicsynchronizedvoidsale(){//product=0;循环次数：0
while(product<=0){
System.out.println("缺货！");

try{
this.wait();
}catch(InterruptedExceptione){
}
}

System.out.println(Thread.currentThread().getName()+":"+--product);
this.notifyAll();
}
}

//生产者
classProductorimplementsRunnable{
privateClerkclerk;

publicProductor(Clerkclerk){
this.clerk=clerk;
}

@Override
publicvoidrun(){
for(inti=0;i<20;i++){
try{
Thread.sleep(200);
}catch(InterruptedExceptione){
}

clerk.get();
}
}
}

//消费者
classConsumerimplementsRunnable{
privateClerkclerk;

publicConsumer(Clerkclerk){
this.clerk=clerk;
}

@Override
publicvoidrun(){
for(inti=0;i<20;i++){
clerk.sale();
}
}
}