publicclassProduct {
//产品数量privateintproductNumber=0;
//生产产品publicsynchronizedvoidproduceProduct(){
if(productNumber<20){
productNumber++;
System.out.println(Thread.currentThread().getName()+"正在生产第"+productNumber+"个产品");
notify();
        }else{
try {
wait();
            } catch (InterruptedExceptione) {
e.printStackTrace();
            }
        }
    }
//消费产品publicsynchronizedvoidconsumerProduct(){
if(productNumber>0){
System.out.println(Thread.currentThread().getName()+"正在消费第"+productNumber+"个产品");
productNumber--;
notify();
        }else{
try {
wait();
            } catch (InterruptedExceptione) {
e.printStackTrace();
            }
        }
    }
}

publicclassProductorextendsThread{
privateProductproduct;
publicProductor(Productproduct){
this.product=product;
    }
@Overridepublicvoidrun() {
System.out.println(getName()+"生产产品.......");
while(true){
try {
Thread.sleep(100);
            } catch (InterruptedExceptione) {
e.printStackTrace();
            }
product.produceProduct();
        }
    }
}

publicclassConsumerextendsThread{
privateProductproduct;
publicConsumer(Productproduct) {
this.product=product;
    }
@Overridepublicvoidrun() {
System.out.println(currentThread().getName()+"消费产品.......");
while(true){
try {
Thread.sleep(100);
            } catch (InterruptedExceptione) {
e.printStackTrace();
            }
product.consumerProduct();
        }
    }
}

publicclassTest {
publicstaticvoidmain(String[] args) {
Productproduct=newProduct();
Productorproductor=newProductor(product);
productor.setName("生产者");
Consumerconsumer=newConsumer(product);
consumer.setName("消费者");
productor.start();
consumer.start();
    }
}