多线程实现生产者消费者案例 [复制链接]

Java案例之生产者与消费者

总体概述：线程生命周期：案例分析：结果预览：具体实现：原码：

总体概述：

所谓生产者消费者问题，实际上主要是包含了两类线程/p>

一类是生产者线程用于生产数据一类是消费者线程用于消费数据为了解耦生产者和消费者的关系，通常会采用共享的数据区域，就像是一个仓库。

生产者生产数据之后直接放置在共享数据区中，并不需要关心消费者的行为消费者只需要从共享数据区中去获取数据，并不需要关心生产者的行为线程生命周期：

案例分析：

生产者消费者案例中包含的类/p>

奶箱类(Box):定义一个成员变量，表示第x瓶奶，提供存储牛奶和获取牛奶的操作生产者类(Producer):实现Runnable接口，重写run()方法，调用存储牛奶的操作消费者类(Customer):实现Runnable接口，重写run()方法，调用获取牛奶的操作测试类(BoxTestt):里面有main方法，main方法中的代码步骤如下：①创建奶箱对象，这是共享数据区域

②创建生产者对象，把奶箱对象作为构造方法参数传递，因为在这个类中要调用存储牛奶的操作

③创建消费者对象，把奶箱对象作为构造方法参数传递，因为在这个类中要调用获取牛奶的操作

④创建2个线程对象，分别把生产者对象和消费者对象作为构造方法参数传递

⑤启动线程

结果预览：

具体实现：

下面是存储牛奶和获取牛奶的操作

//定义一个成员变量，用来表示第x瓶牛奶privateintmilk;//定义一个成员变量用于表示牛奶箱子状态privatebooleanstate=false;//提供存储牛奶和获取牛奶的操作publicsynchronizedvoidputMilk(intmilk){if(state){try{wait();}catch(InterruptedExceptione){e.printStackTrace();}}//如果没有牛奶则生产牛奶this.milk=milk;System.out.println(送奶工人将第+this.milk+瓶牛奶放入奶箱);//生产完毕修改牛奶箱子状态state=true;//唤醒其他等待的线程notifyAll();}publicsynchronizedvoidgetMilk(){//如果没有牛奶等待生产if(!state){try{wait();}catch(InterruptedExceptione){e.printStackTrace();}}//如果有牛奶就消费牛奶System.out.println(用户拿到第+this.milk+瓶牛奶);//生产完毕修改牛奶状态state=false;//唤醒其他等待的线程notifyAll();}原码：

生产者类：

packageMultithreadingCase;publicclassProducerimplementsRunnable{privatefinalBoxb;publicProducer(Boxb){this.b=b;}

packageMultithreadingCase;publicclassCustomerimplementsRunnable{privatefinalBoxb;publicCustomer(Boxb){this.b=b;}

packageMultithreadingCase;publicclassBoxTest{publicstaticvoidmain(String[]args){//创建奶箱对象用于共享数据Boxbox=newBox();//创建生产者对象把奶箱对象（box）作为构造方法参数传递调用存储牛奶操作Producerp=newProducer(box);//创建消费者对象把奶箱对象（box）作为构造方法参数传递调用获取牛奶操作Customerc=newCustomer(box);//创建两个线程，把生产者对象和消费者对象作为构造方法参数传进去Threadt1=newThread(p);Threadt2=newThread(c);//启动两个线程t1.start();t2.start();}}牛奶箱子类：

packageMultithreadingCase;publicclassBox{//定义一个成员变量，用来表示第x瓶牛奶privateintmilk;//定义一个成员变量用于表示牛奶箱子状态privatebooleanstate=false;//提供存储牛奶和获取牛奶的操作publicsynchronizedvoidputMilk(intmilk){if(state){try{wait();}catch(InterruptedExceptione){e.printStackTrace();}}//如果没有牛奶则生产牛奶this.milk=milk;System.out.println(送奶工人将第+this.milk+瓶牛奶放入奶箱);//生产完毕修改牛奶箱子状态state=true;//唤醒其他等待的线程notifyAll();}publicsynchronizedvoidgetMilk(){//如果没有牛奶等待生产if(!state){try{wait();}catch(InterruptedExceptione){e.printStackTrace();}}//如果有牛奶就消费牛奶System.out.println(用户拿到第+this.milk+瓶牛奶);//生产完毕修改牛奶状态state=false;//唤醒其他等待的线程notifyAll();}},