生产者与消费者应用案例

小鱼儿 2021-10-18 09:48 363阅读 0赞

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pzMTM0MjA4NDc3Ng_size_16_color_FFFFFF_t_70][]

![20190811095332272.png][]

![20190811105954355.png][]

package com.vince;
    /**
     * 两个线程协同工作，先生产，再消费
     *  wait():当前线程停止运行，被同一个线程锁的其它线程唤醒之后才能接着运行
     *  notify(): 唤醒同一个同步锁中某一个wait()锁
     *
     * sleep和wait的区别：
     * sleep: 让线程进入休眠状态，让出CPU的时间片，不释放对象监视器的所有权(对象锁)
     * wait：让线程进入等待状态，让出CPU的时间片，并释放对象监视器的所有权(对象锁)，等待其它线程通过notify方法唤醒
     */
    public class ProducterCustomerDemo {
        public static void main(String[] args) {
            Food food = new Food();
            Producter p = new Producter(food);
            Customers c = new Customers(food);
            Thread t1 = new Thread(p);
            Thread t2 = new Thread(c);
            t1.start();
            t2.start();
        }
    }
    /**
     * 消费者
     */
    class Customers implements Runnable{
        private  Food food;
        public Customers(Food food){
            this.food = food;
        }
        @Override
        public void run() {
            for (int i = 0; i < 5; i++) {
                food.get();
            }
        }
    }
    
    /**
     * 生产者
     */
    class Producter implements Runnable{
        private Food food;
    
        public Producter(Food food){
            this.food = food;
        }
        @Override
        public void run() {
             for(int i = 0; i < 5; i++){
                 if(i %2 == 0){
                     food.set("锅巴肉","酸甜口味,爽");
                 }else{
                     food.set("佛跳墙","大补，滋阴补阳");
                 }
             }
        }
    }
    
    /**
     * 食物
     */
    class Food{
        private String name;
        private String desc;//描述
        private  boolean flag = true; //true表示可以生产，false表示可以消费
        /**
         * 生产产品
         */
       public synchronized void set(String name,String desc){
            //不能生产
           if(!flag){
               try {
                   this.wait();//线程进入等待状态，释放监视器的所有权（对象锁）
               } catch (InterruptedException e) {
                   e.printStackTrace();
               }
           }
            this.setName(name);
            try {
                Thread.sleep(500);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            this.setDesc(desc);
            flag = false;
            this.notify();//唤醒等待的线程（随机其中一个）
        }
        /**
         * 消费产品
         */
       public synchronized void get(){
           //不能消费
           if(flag){
               try {
                   this.wait();
               } catch (InterruptedException e) {
                   e.printStackTrace();
               }
           }
            try {
                Thread.sleep(500);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println(this.getName()+"->"+this.getDesc());
            flag = true;
            this.notify();//唤醒等待的线程（随机其中一个）
        }
    
        public String getName() {
            return name;
        }
    
        public void setName(String name) {
            this.name = name;
        }
    
        public String getDesc() {
            return desc;
        }
    
        public void setDesc(String desc) {
            this.desc = desc;
        }
    
        public Food(String name, String desc) {
            this.name = name;
            this.desc = desc;
        }
    
        public Food() {
        }
    
        @Override
        public String toString() {
            return "Food{" +
                    "name='" + name + '\'' +
                    ", desc='" + desc + '\'' +
                    '}';
        }
    }

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pzMTM0MjA4NDc3Ng_size_16_color_FFFFFF_t_70 1][]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pzMTM0MjA4NDc3Ng_size_16_color_FFFFFF_t_70]: /images/20211018/9d7ad2656a174d3ebd2f18882512493c.png
[20190811095332272.png]: /images/20211018/cdfd85d548bb4823b4e6b8081f6792fe.png
[20190811105954355.png]: /images/20211018/04f73510ae724ad4bde7c3c3af1c9684.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pzMTM0MjA4NDc3Ng_size_16_color_FFFFFF_t_70 1]: /images/20211018/998f3d95a13045e1b2f7ae64493dc825.png