线程通信:生产者和消费者

墨蓝 2023-10-02 19:37 25阅读 0赞

使用等待唤醒机制实现生产者，消费者案例![9b3e13e1476841969892846ecbcc1e6c.png][]

桌子:

package 生产者和消费者;
    
    import java.util.concurrent.locks.Lock;
    
    //桌子
    public class Desk {
        //汉堡个数
        public static int hanbao=1;
        //定义唯一的lock锁对象
        public static final Object lock = new Object();
    }

消费者:吃货

package 生产者和消费者;
    
    import java.awt.*;
    
    /**
     * 消费者步骤：
     * 1，判断桌子上是否有汉堡包。
     * 2，如果没有就等待。
     * 3，如果有就开吃
     * 4，吃完之后，桌子上的汉堡包就没有了
     *      叫醒等待的生产者继续生产
     *      汉堡包的总数量减一
     *
     *     消费者:吃货
     */
    public class Foodie implements Runnable {
        @Override
        public void run() {
            //死循环:让程序一直执行,方便查看
            while (true) {
                //同步代码块
                synchronized (Desk.lock) {
                    //判断桌子上是否有食物
                    if (Desk.hanbao == 1) {
                        //有汉堡就吃
                        System.out.println(Thread.currentThread().getName() + "吃了一个汉堡");
                        Desk.hanbao = 0;//修改桌子上汉堡数量
                    } else {
                        //没有汉堡,等待(厨师制作)
                        try {
                            Desk.lock.wait();//等待
                        } catch (InterruptedException e) {
                            e.printStackTrace();
                        }
                    }
                    Desk.lock.notify();//唤醒厨师
                }
                try {
                    Thread.sleep(1000);//睡眠,方便观察
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
    
        }
    }

生产者:厨师

package 生产者和消费者;
    
    import java.awt.*;
    
    /**
     * 消费者步骤：
     * 1，判断桌子上是否有汉堡包。
     * 2，如果没有就等待。
     * 3，如果有就开吃
     * 4，吃完之后，桌子上的汉堡包就没有了
     *      叫醒等待的生产者继续生产
     *      汉堡包的总数量减一
     *
     *      生产者:厨师
     */
    public class Cooker implements Runnable {
    
        @Override
        public void run() {
            //死循环:让程序一直执行,方便查看
            while (true) {
                //同步代码块
               synchronized (Desk.lock){
                   //1.判断桌子上是否有汉堡
                   if (Desk.hanbao == 1) {
                       //有汉堡:就等待吃货来吃
                       try {
                           Desk.lock.wait();//等待
                       } catch (InterruptedException e) {
                           e.printStackTrace();
                       }
                   } else {
                       //没有汉堡,就开始生产
                       System.out.println(Thread.currentThread().getName()+"生产了一个汉堡");
                       Desk.hanbao=1;//汉堡+1,放在桌子上
                   } Desk.lock.notify();//叫醒消费者开始吃
               }
            }
        }
    }

测试类

package 生产者和消费者;
    
    public class Test {
        public static void main(String[] args) {
            Cooker cooker = new Cooker();
            new Thread(cooker, "厨师").start();
    
            Foodie foodie = new Foodie();
            new Thread(foodie, "吃货").start();
        }
    }

[9b3e13e1476841969892846ecbcc1e6c.png]: https://img-blog.csdnimg.cn/9b3e13e1476841969892846ecbcc1e6c.png