建议学习视频:https://www.bilibili.com/video/BV18J411W7cE?p=324
一、线程知识点大纲
二、消费者与生产者模型
1、生产者:送奶工
package procus; public class Producer implements Runnable { private Box b; public Producer(Box b) { this.b=b; } public void run() { for(int i=1;i<=30;i++) { b.put(i); } } }
2、公共数据区域:奶箱
package procus; public class Box { //定义一个成员变量,表示第X瓶奶 private int milk;//定义一个成员变量,表示奶箱的状态 private boolean state=false; //提供存储牛奶和获取牛奶的操作 public synchronized void put(int milk) { //如果有牛奶,等待消费 if(state==true) { try { //this.wait(); wait(); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } } //如果没有牛奶,就生产牛奶 this.milk=milk; count++; System.out.println("送奶工将第"+this.milk+"瓶奶放入奶箱"); //生产完毕之后,修改奶箱状态 state=true; //唤醒其他等待的线程 notifyAll(); } public synchronized void get() { //如果没有牛奶,等待生产 if(!state) { try { //this.wait(); wait(); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } } //如果有牛奶,就消费牛奶 System.out.println("用户拿到第"+milk1+"瓶奶"); //消费完毕之后,修改奶箱状态 state=false; //唤醒其他等待的线程 //this.notifyAll(); notifyAll(); } }
3、消费者:用户
package procus; public class Customer implements Runnable { private Box b; public Customer(Box b) { this.b=b; } public void run() { while(true) { b.get(); } } }
4、测试类
package procus; public class BoxDemo { public static void main(String[] args) { //创建奶箱对象,这是共享数据区域 Box b=new Box(); //创建生产者对象,把奶箱对象作为构造方法参数传递,因为在这个类中要调用存储牛奶的操作 Producer p=new Producer(b); //创建消费者对象,把奶箱对象作为构造方法参数传递,因为在这个类中要调用获取牛奶的操作 Customer c=new Customer(b); //创建2个线程对象,分别把生产者和消费者作为构造方法参数传递 Thread t1=new Thread(p,"陆婷"); Thread t2=new Thread(c,"赵粤"); //启动线程 t1.start(); t2.start(); } }
5、输出结果:
6、假设新增一项需求:用户不是等送奶工送一瓶奶就喝一瓶,而是奶箱有一个特定的容量,送奶工会一直送奶,直到达到奶箱的容量,然后用户再喝掉所有的奶。那么此时,该程序就需要(在Box类中)进行如下步骤的改进:
①声明奶箱最大容量(假设为5瓶)
//定义一个成员变量,表示奶箱最大的容量为5瓶 private final int capacity=5;
②再声明一个成员变量,表示奶箱中的牛奶总瓶数,用来判断奶箱是否装满了牛奶
//定义一个成员变量,表示奶箱中的牛奶总瓶数 private int count=0;
③在put方法等待消费的try-catch语句块中新增一个判断条件,即判断奶箱是否装满了牛奶
//如果有牛奶,等待消费 if(state==true && count%capacity==0) { try { //this.wait(); wait(); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } }
④在get方法消费牛奶的输出语句之前,加上一个for循环,使用户一次性取走5瓶牛奶
//如果有牛奶,就消费牛奶 for(int milk1=this.milk-4;milk1<=this.milk;milk1++) System.out.println("用户拿到第"+milk1+"瓶奶");
⑤这次的输出结果为: