JAVA 多线程实现包子铺（买包子，吃包子）

package baozi;

/*
    生产者（包子铺）类：是一个 线程类，继承Thread
    设置线程任务（run）：生产包子
    对包子 进行判断
    true：有包子
        包子铺调用wait方法进入等待状态
     false : 没有包子
        包子铺生产包子
        交替生产两种包子
            有两种状态（i%2==0）
         包子铺生产两种包子
         修改包子的状态为true有
         唤醒吃货线程，让吃货线程吃包子

     注意：
        包子铺线程和包子线程关系-->通信（互斥）
        锁对象必须保证唯一，可以使用包子对象作为锁对象
        包子铺类和吃货的类 就需要把保安资质对象作为参数传递进来
            1，需要在成员位子创建一个包子变量
            2，使用带参数构造方法。为这个包子变量赋值

 */
public class BaoZIPu extends Thread {
    private BaoZi bz;

    public BaoZIPu(BaoZi bz){
        this.bz=bz;
    }

    @Override
    public void run() {
        int count = 0;
        while (true) {
            //同步技术
            synchronized (bz) {
                //判断有没有包子
                if (bz.flag == true) {
                    //包子铺调用wait反法进入等待状态
                    try {
                        bz.wait();
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
                //被唤醒之后执行，包子铺生产包子
                //生产两种包子
                if (count % 2 == 0) {
                    bz.pi = "薄皮";
                    bz.xian = "猪肉";
                } else {
                    bz.pi = "厚皮";
                    bz.xian = "牛肉";
                }
                count++;
                System.out.println("包子铺正在生产" + bz.pi + bz.xian + "的包子");
                try {
                    Thread.sleep(1000);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                //包子铺生产好了包子
                //修改包子的状态为true
                bz.flag = true;
                //唤醒吃货线程，让吃货线程吃包子
                bz.notify();
                System.out.println("包子铺已经生产好了" + bz.pi + bz.xian + "的包子，吃货可以开始吃了");
            }
        }
    }
}

package baozi;

/*
    设置包子的属性
        皮
        馅
        包子的状态：有 true 没有 false
 */
public class BaoZi {
    String pi;
    String xian ;
    //包子的状态 有 true 没有 fasle
    boolean flag =false;
}

package baozi;

import baozi.BaoZi;

public class ChiHuo extends  Thread {
    private BaoZi bz;
    public  ChiHuo(BaoZi bz){
        this.bz=bz;
    }
    @Override
    public void run() {
        while(true){
            synchronized (bz){
                if (bz.flag==false){
                    try {
                        bz.wait();
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
                //被唤醒后执行的代码 ，吃包子
                System.out.println("吃货正在吃"+bz.pi+bz.xian+"的包子");
                bz.flag=false;
                bz.notify();
                System.out.println("吃货已经把"+bz.pi+bz.xian+"的包子出完了，包子铺开始生产包子 ");
                System.out.println("++++++++++++++");
            }
        }
    }
}

package baozi;

import baozi.BaoZIPu;
import baozi.BaoZi;
import baozi.ChiHuo;

public class Main {
    public static void main(String[] args) {
        BaoZi bz = new BaoZi();
        //创建包子铺线程，开始生产包子
        new BaoZIPu(bz).start();
        //创建吃货线程，开启，吃包子
        new ChiHuo(bz).start();
    }

}

运行代码?