福州专业网站建设价格/无锡百度快速优化排名

概述：

（java的线程调度模式采用的是抢占式调度）

生产者消费者是一个十分经典的多线程协作模式，弄懂生产者消费者问题能够让我们对多线程编程的理解更加深刻。

所谓生产者问题，实际上主要是包含了两类线程：

• 一类是生产者线程用于生产数据；
• 一类是消费者用于消费数据；
• 为了解耦生产者和消费者的关系，通常会采用共享的**数据区域**，就像是一个仓库，生产者生产数据之后直接放置在共享区域中，并不需要关心消费者的行为。
• 消费者只需要从共享区域中获取数据，并不需要关心生产者的行为。

为了体现生产和消费过程中的等待和唤醒，java中提供了几个方法供我们使用，这几个方法在Object类中，分别是wait()、notify()、notifyAll()三个方法。

三个核心点：

• 任何对象中都一定有着三个方法（因为任意类都继承自Object类）
• 只有作为锁对象的时候，才可以调用
• 只有在同步的代码块中，才可以调用

其他情况下，调用一个对象的这三个方法，都会报错。

• void wait() ：导致当前线程进入无限期等待状态，直到另一个线程调用该对象的notify()方法或notifyAll()方法。
• void notify() : 随机唤醒一个正在等待对象监视器的线程。
• void notifyAll() ：唤醒正在等待对象监视器的所有线程。

需求：

奶箱类（Box),定义一个成员变量，表示第x瓶奶，提供存储牛奶和获取牛奶的操作。

生产者类（product），实现Runnable接口，重写run()方法，调用存储牛奶的操作。

消费者类（Customer），实现Runnable接口，重写run()方法，调用获取牛奶的操作。

测试类（Test），里面有main方法，main方法中的调用步骤如下：

1. 创建奶箱对象，这是共享数据区域
2. 创建生产者对象，把奶箱对象通过构造方法进行参数传递，因为在这个类中，要调用存储牛奶的操作。
3. 创建消费者对象，把奶箱对象通过构造方法进行参数传递，因为在这个类中，要调用获取牛奶的操作
4. 创建两个线程对象，分别把生产者和消费者对象作为构造方法参数传递。
5. 启动线程

1、创建奶箱对象，这是共享数据区域

奶箱类中定义了一个奶箱数量milk和奶箱状态state，以及存储牛奶和获取牛奶的操作。

package CoreJava.day15_thread.product;/*** Created by Intellij IDEA.** @author zhudezhong* @date 2021/6/27 20:52*/
//奶箱
public class Box {//定义牛奶的数量private int milk;//定义一个奶箱状态private boolean state = false;  //true表示奶箱有奶，false表示奶箱无奶//存取牛奶public synchronized void put(int milk) {if (state) {//奶箱有奶，则让停止往奶箱中放奶,等待消费者消费try {wait();} catch (InterruptedException e) {e.printStackTrace();}}//奶箱中没有奶，往其中放牛奶this.milk = milk;System.out.println("生产者生产了第" + milk + "瓶牛奶");//放完奶之后让奶箱的状态变为truestate = true;//唤醒消费者，来拿牛奶notifyAll();}//拿到牛奶public synchronized void get() {//奶箱中没有牛奶，等待生产者生产牛奶if (!state){try {wait();} catch (InterruptedException e) {e.printStackTrace();}}//有牛奶，获取牛奶System.out.println("送奶工拿到了第" + milk + "瓶牛奶");//获取玩牛奶后改变奶箱状态state = false;//唤醒生产者来生产notifyAll();}}

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

生产者类中，定义了一个有参构造方法，该参数是奶箱（Box）对象。这个参数传递的方式保证了我们传入的奶箱是同一个奶箱，创造一个了数据共享区域

package CoreJava.day15_thread.product;/*** Created by Intellij IDEA.** @author zhudezhong* @date 2021/6/27 20:52*/
//生产者
public class Product implements Runnable {private Box box;//该构造方法可以确保传入的box奶箱是同一个对象public Product(Box box) {this.box = box;}@Overridepublic void run() {//放入牛奶for (int i = 1; i <= 5; i++) {box.put(i);}}
}

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

package CoreJava.day15_thread.product;/*** Created by Intellij IDEA.** @author zhudezhong* @date 2021/6/27 20:52*/
//消费者
public class Custermor implements Runnable{private Box box;public Custermor(Box box) {this.box = box;}@Overridepublic void run() {//一直取牛奶while (true){box.get();}}
}

4、测试类（Test）

package CoreJava.day15_thread.product;/*** Created by Intellij IDEA.** @author zhudezhong* @date 2021/6/27 20:53*/
public class Test {public static void main(String[] args) {//创建奶箱对象Box box = new Box();//创建生产者、消费者任务对象Product product = new Product(box);Custermor custermor = new Custermor(box);//创建并启动生产者消费者线程Thread t1 = new Thread(product);Thread t2 = new Thread(custermor);t1.start();t2.start();}
}

运行结果：