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

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();//生产产品

}

}

}