JUC学习之生产者消费者案例-synchronized-虚假唤醒

时间:2022-09-21 10:14:09

本文为看视频学习记录,若有错误请指正!

在实际开发过程中,我们可以将添加和创建数据的线程看做是生产者,删除和销毁数据的线程看做是消费者。
若不用等待唤醒机制,假设生产者过快,消费者跟不上,那么会导致数据的丢失;
                                  假设消费者过快,生产者跟不上,那么可能会导致重复的数据或者是错误的数据;

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

运行结果:

JUC学习之生产者消费者案例-synchronized-虚假唤醒

但是这样的写法仍然存在问题,当我们对当前的代码进行稍稍修改,

JUC学习之生产者消费者案例-synchronized-虚假唤醒

JUC学习之生产者消费者案例-synchronized-虚假唤醒

把商品的数量的上限设置成1,并且让生产者的方法延迟0.2秒

JUC学习之生产者消费者案例-synchronized-虚假唤醒

此时,输出结果已经停止,但是发现程序却没有停止,导致这个问题的原因是:if-else语句的问题

JUC学习之生产者消费者案例-synchronized-虚假唤醒

解决当前问题的方法是:去掉if判断的else部分
JUC学习之生产者消费者案例-synchronized-虚假唤醒
修改之后的运行结果

JUC学习之生产者消费者案例-synchronized-虚假唤醒

但是这样还是会出现问题,因为现在是一个生产者一个消费者,非A即B,相对来说不会出大问题,但是若是有多个生产者多个消费者,那么导致虚假唤醒问题

JUC学习之生产者消费者案例-synchronized-虚假唤醒

当多个消费者被等待,然后生产者被唤醒生产商品,再唤醒被等待的消费者进程,多个消费者进程都继续向下执行,就会导致消费的产品数量大于生产的数据,然后product的值就会有负值。
在API中已经有过这样的介绍,对于wait(),中断和虚假唤醒是可能存在的,因此,这个方法一定要在循环中使用
JUC学习之生产者消费者案例-synchronized-虚假唤醒
因此,需要把代码中的if换成while,让被唤醒的进程重新去判断一遍while中的条件
JUC学习之生产者消费者案例-synchronized-虚假唤醒