标签：MessageObject 消费者 Thread mo 模式 flag new 多线程 public

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();
        }
    }
}

运行结果：

标签：MessageObject,消费者,Thread,mo,模式,flag,new,多线程,public
来源： https://blog.csdn.net/lierenbiji21/article/details/119453254

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。