本文为看视频学习记录,若有错误请指正!
在实际开发过程中,我们可以将添加和创建数据的线程看做是生产者,删除和销毁数据的线程看做是消费者。
若不用等待唤醒机制,假设生产者过快,消费者跟不上,那么会导致数据的丢失;
假设消费者过快,生产者跟不上,那么可能会导致重复的数据或者是错误的数据;
synchronized写法-等待唤醒
public class TestProductorAndCustomer {
public static void main(String[] args){
Clerk clerk = new Clerk();
Productor productor = new Productor(clerk);
Customer customer = new Customer(clerk);
new Thread(productor,"productor A").start();
new Thread(customer,"customer A").start();
}
}
class Clerk {
private int productor = 0;
//进货
public synchronized void get() {
if (productor >= 10) {
System.out.println("产品已满!");
try {
this.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
} else {
System.out.println(Thread.currentThread().getName() + ":" + ++productor);
this.notifyAll();
}
}
//卖货
public synchronized void sale() {
if (productor <= 0) {
System.out.println("缺货!");
try {
this.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
} else {
System.out.println(Thread.currentThread().getName() + ":" + --productor);
this.notifyAll();
}
}
}
class Productor implements Runnable{
private Clerk clerk;
public Productor(Clerk clerk) {
this.clerk = clerk;
}
@Override
public void run() {
for (int i = 0; i < 20; i++) {
clerk.get();
}
}
}
class Customer implements Runnable{
private Clerk clerk;
public Customer(Clerk clerk) {
this.clerk = clerk;
}
@Override
public void run() {
for (int i = 0; i <20 ; i++) {
clerk.sale();
}
}
}
运行结果:
但是这样的写法仍然存在问题,当我们对当前的代码进行稍稍修改,
把商品的数量的上限设置成1,并且让生产者的方法延迟0.2秒
此时,输出结果已经停止,但是发现程序却没有停止,导致这个问题的原因是:if-else语句的问题
解决当前问题的方法是:去掉if判断的else部分
修改之后的运行结果
但是这样还是会出现问题,因为现在是一个生产者一个消费者,非A即B,相对来说不会出大问题,但是若是有多个生产者多个消费者,那么导致虚假唤醒问题
当多个消费者被等待,然后生产者被唤醒生产商品,再唤醒被等待的消费者进程,多个消费者进程都继续向下执行,就会导致消费的产品数量大于生产的数据,然后product的值就会有负值。
在API中已经有过这样的介绍,对于wait(),中断和虚假唤醒是可能存在的,因此,这个方法一定要在循环中使用
因此,需要把代码中的if换成while,让被唤醒的进程重新去判断一遍while中的条件