多线程-生产消费者模式

你的名字 2022-09-03 08:24 160阅读 0赞

package com.thread.cusproform;
    
    ```java
    /**
     * @Author yg_wu
     * @Description //生产消费者模式，生产一个商品消费一个商品
     * @Date 2021/8/6 10:40
     **/
    public class CPFTTest {
        
        public static void main(String[] args) {
        
            MessageObject messageObject = new MessageObject(true);
    
            ProT proT = new ProT(messageObject);
            CusT cusT = new CusT(messageObject);
    
            new Thread(cusT).start();
            new Thread(proT).start();
        }
    }
    /**
     * @Author yg_wu
     * @Description //生产完成开关对象
     * @Date 2021/8/6 10:43
     **/
    class MessageObject {
        
        private boolean flag;
    
        public MessageObject(boolean flag) {
        
            this.flag = flag;
        }
    
        public void setFlag(boolean flag) {
        
            this.flag = flag;
        }
    
        public boolean isFlag() {
        
            return flag;
        }
        public void function() throws Exception{
        
            synchronized (MessageObject.class) {
        
                if (flag) {
        
                    Thread.sleep(3000);
                    System.out.println("生产者生产了一个商品");
                    Thread.sleep(1000);
                    flag = false;
                } else {
        
                    Thread.sleep(2000);
                    System.out.println("消费者消费了一个商品");
                    flag = true;
                }
            }
        }
    }
    
    //生产线程负责调用生产线不断生产
    class ProT extends Thread {
        
        public MessageObject mo;
    
        public ProT(MessageObject mo) {
        
            this.mo = mo;
        }
    
        @Override
        public void run() {
        
            try {
        
                while (true){
        
                    mo.function();
                }
            } catch (Exception e) {
        
                e.printStackTrace();
            }
        }
    }
    
    //消费线程辅助调用消费线不断消费
    class CusT extends Thread {
        
        public MessageObject mo;
    
        public CusT(MessageObject mo) {
        
            this.mo = mo;
        }
    
        @Override
        public void run() {
        
            try {
        
                while (true) {
        
                    mo.function();
                }
            } catch (Exception e) {
        
                    e.printStackTrace();
            }
        }
    }

运行结果：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xpZXJlbmJpamkyMQ_size_16_color_FFFFFF_t_70]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xpZXJlbmJpamkyMQ_size_16_color_FFFFFF_t_70]: /images/20220829/e88f897f4f61423e899a43938793c98a.png