在生产者与消费者模型中,生产者不断生产,消费者不断取走生产者生产的产品。
生产者生产出信息后将其放到一个区域中,然后消费者从此区域里取出数据,但是在本程序中因为牵扯到线程运行的不确定性,所以会在存在以下两点问题:
(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略
}
生产者每生产一个信息就要等待消费者取走,消费者每取走一个信息就要等待生产者生产,这样就避免了重复生产和重复取走的问题。