本文为看视频学习记录,若有错误请指正!
在实际开发过程中,我们可以将添加和创建数据的线程看做是生产者,删除和销毁数据的线程看做是消费者。
若不用等待唤醒机制,假设生产者过快,消费者跟不上,那么会导致数据的丢失;
假设消费者过快,生产者跟不上,那么可能会导致重复的数据或者是错误的数据;
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中的条件