Java开发-Java中生产者与消费者设计模式的实现

在生产者与消费者模型中,生产者不断生产,消费者不断取走生产者生产的产品。
生产者生产出信息后将其放到一个区域中,然后消费者从此区域里取出数据,但是在本程序中因为牵扯到线程运行的不确定性,所以会在存在以下两点问题:
(1)假设生产者线程向数据存储空间添加信息的名称,还没有加入该信息的内容,程序就切换到了消费者线程,消费者线程将把该信息的名称和上一个信息的内容联系到一起。
(2)生产者放了若干次的数据,消费者才开始取数据,或者是消费者取完一个数据后,还没等到生产者放入新的数据,又重复取出已取过的数据。
解决该问题必须引入生产者与消费者的设计模式。

  • 生产者与消费者设计模式的逻辑代码:
class Message {
    private String title;
    private String content;
    private boolean flag = true;
    // flag == true:表示可以生产,但是不能取走
    // flag == false:表示可以取走,但是不能生产
    public synchronized void set(String title, String content) {
        if (this.flag == false) {               // 已经生产过了,不能生产
            try {
                super.wait();                   // 等待
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        this.title = title;
        try {
            Thread.sleep(200);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        this.content = content;
        this.flag = false;                      // 已经生产完成,修改标志位
        super.notify();                         // 唤醒等待线程
    }
    public synchronized void get() {
        if (this.flag == true) {                // 未生产,不能取走
            try {
                super.wait();                   // 等待
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        try {
            Thread.sleep(100);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println(this.title + " --> " + this.content);
        this.flag = true;                       // 已经取走了,可以继续生产
        super.notify();                         // 唤醒等待线程
    }
    // setter、getter略
}

生产者每生产一个信息就要等待消费者取走,消费者每取走一个信息就要等待生产者生产,这样就避免了重复生产和重复取走的问题。


猜你喜欢

转载自blog.csdn.net/fukaimei/article/details/78721287