wait notify之虚假唤醒

虚假唤醒的概念

jdk官方文档解释:

所以说在wait和notify一块使用时,如果使用if作为条件时,会有虚假唤醒的情况发生,所以必须使用while作为循环条件。下面来举例实验:

首先,创建一个资源类:(在多线程中,一般都是资源类和线程操作解耦,不放在用同一个类中,只有在线程操作资源类时,才会创建资源类的对象)

package com.test;

/** * 资源类 * @author Huxudong * @createTime 2020-04-01 21:57:39 **/public class Resource {    /** 产品数 */    private int product = 0;

    /** 进货 */    public synchronized void get() {        if(product >= 10) {            System.out.println(Thread.currentThread().getName()+":"+"产品已满!");            /** 当商品已经满的时候,进货线程挂起 */            try {                this.wait();            } catch (InterruptedException e) {                e.printStackTrace();            }        }

        /** 进货 */        System.out.println(Thread.currentThread().getName()+":"+ ++product);        /** 唤醒其他线程 */        this.notifyAll();

    }

    /** 售货 */    public synchronized void sale() {        if(product <= 0) {            System.out.println(Thread.currentThread().getName()+":"+"产品已空");            try {                this.wait();            } catch (InterruptedException e) {                e.printStackTrace();            }        }

        /** 售货 */        System.out.println(Thread.currentThread().getName()+":"+ --product);        /** 唤醒其他线程 */        this.notify();    }}

然后再创建线程来操作我们的资源类(通过java8新特性Lambda表达式直接创建)
package com.test;

import java.util.concurrent.TimeUnit;

/** * 线程操作资源类,实现线程与资源类的解耦合 * @author Huxudong * @createTime 2020-04-01 23:13:54 **/public class TestPc {    public static void main(String[] args) {        Resource resource = new Resource();        new Thread(()->{            for (int i = 0; i < 20; i++) {                try {                    /** 睡眠,便于观察结果 */                    TimeUnit.SECONDS.sleep(2);                } catch (InterruptedException e) {                    e.printStackTrace();                }                resource.get();            }        },"生产者A").start();

        new Thread(()->{            for (int i = 0; i < 20; i++) {                resource.sale();            }

        },"消费者C").start();

        new Thread(()->{            for (int i = 0; i < 20; i++) {

                resource.get();            }

        },"生产者B").start();

        new Thread(()->{            for (int i = 0; i < 20; i++) {                resource.sale();            }

        },"消费者D").start();    }}

先来看看如果使用if条件会发生什么:

对,你没看错,怎么可能会出现负数呢,这肯定是不对的。冷静下来分析一下,还是有点头绪,知道哪里出现了问题的(那你是一个处事不惊的人,很厉害)。

来,分析一下,一开始先调用了消费者C,D线程(因为我们写了睡眠在生产者中),消费者此时发现此时product资源为0,所以,消费者C,D这两个兄弟,没办法只能调用wait方法,睡眠了,并且释放了锁。

但是此时第一个消费者已经苏醒了,发动机开始生产产品了,并且生产之后,又唤醒了所有等待的消费者线程。这消费者C,D两兄弟终于苏醒了,D哥们先获得了锁,所以就先消费了一个产品,然后就又发现没有产品了,又伤心的休眠去了,但是不要忘了,此时还有一个C哥们被唤醒了啊,你唤醒了人家,人家总的干点什么事情吧,不然这多难受,刚好不巧的是,此时的判断条件是if,所以此时C哥们便不受条件的约束,接着上面自己睡眠的代码处执行,毅然决然的又去消费了一个产品,原来D哥们消费后,就已经为0了,这个C哥们再去消费减一,不就是-1了吗,以此类推分析。发现如果判断条件用不好,此时唤醒的C哥们就相当于虚假唤醒的了,会给程序带来不可预估的错误。所以在这里判断必须要使用while,先来看看把if换成while的结果。

这回结果就比较正常了,为什么使用while就可以呢,因为像上文所说,即使唤醒了所有的消费者线程,此时会不停while循环判断,如果此时条件是为0,那么C哥们就不能出while,那么他也就不回执行下面消费产品的减减操作了,那么就会避免了这种错误。这也是官方提倡的在使用wait  和notifyAll的时候,必须使用while循环条件判断。

原文地址:https://www.cnblogs.com/clover-forever/p/12616869.html

时间: 2024-11-08 23:05:49

wait notify之虚假唤醒的相关文章

java多线程 生产者消费者案例-虚假唤醒

package com.java.juc; public class TestProductAndConsumer { public static void main(String[] args) { Clerk clerk = new Clerk(); Produce produce = new Produce(clerk); Consumer consumer = new Consumer(clerk); new Thread(produce, "线程A").start(); ne

【转】pthread_cond_signal 虚假唤醒问题

引用:http://blog.csdn.net/leeds1993/article/details/52738845 什么是虚假唤醒? 举个例子,我们现在有一个生产者-消费者队列和三个线程. I.1号线程从队列中获取了一个元素,此时队列变为空. II.2号线程也想从队列中获取一个元素,但此时队列为空,2号线程便只能进入阻塞(cond.wait()),等待队列非空. III.这时,3号线程将一个元素入队,并调用cond.notify()唤醒条件变量. IV.处于等待状态的2号线程接收到3号线程的唤

(三)juc高级特性——虚假唤醒 / Condition / 按序交替 / ReadWriteLock / 线程八锁

8. 生产者消费者案例-虚假唤醒 参考下面生产者消费者案例: /* * 生产者和消费者案例 */ public class TestProductorAndConsumer { public static void main(String[] args) { Clerk clerk = new Clerk(); Productor pro = new Productor(clerk); Consumer cus = new Consumer(clerk); new Thread(pro, "生产

生产者消费者和虚假唤醒

1 定义 虚假唤醒,即spurious wakeups.wait需要在while循环内使用,原因就是因为存在虚假唤醒. 2 Monitor 还是放上这个神图来复习下线程间通信 线程在竞争锁失败的情况下会放到Entry Set中,图中2表示线程可以获取锁 获取到锁的线程可以调用wait方法,让线程阻塞,此时线程被放到了Wait Set中,如图中3所示:Wait Set中的线程在时间到或者被notify后可以竞争锁,如图中4所示 Wait Set中的线程在获取到锁后才可以继续执行. notify会唤

【转】通过生产者消费者案例理解等待唤醒机制和虚假唤醒

首先引入下面这段生产者和消费者的程序,店员类作为生产产品和消费产品的中介,其中的数据product为共享数据,产品最多只能囤积5个,当产品达到5个还在生产时,就会提示"产品已满!",类似地,如果产品只有0个了还在消费,会提示"缺货!": 1 package concurrent; 2 3 //店员类 4 class Clerk { 5 private int product = 0; 6 7 // 进货 8 public synchronized void get(

多线程编程中条件变量和的spurious wakeup 虚假唤醒

1. 概述 条件变量(condition variable)是利用共享的变量进行线程之间同步的一种机制.典型的场景包括生产者-消费者模型,线程池实现等. 对条件变量的使用包括两个动作: 1) 线程等待某个条件, 条件为真则继续执行,条件为假则将自己挂起(避免busy wait,节省CPU资源): 2) 线程执行某些处理之后,条件成立:则通知等待该条件的线程继续执行. 3) 为了防止race-condition,条件变量总是和互斥锁变量mutex结合在一起使用. 一般的编程模式: C++代码  

什么是虚假唤醒 spurious wakeup

解释一下什么是虚假唤醒? 说具体的例子,比较容易说通. pthread_mutex_t lock; pthread_cond_t notempty; pthread_cond_t notfull; void *producer(void *data){ for(int i = 0;i<=16;i++){ pthread_mtext_lock(&lock); while(buffer if full){ pthread_cond_wait(&notfull, &lock); }

生产者与消费者案例-虚假唤醒

以下是一个案例,有一个店员,负责进货和卖货.进货生产,卖货消费. 当商品超过10件,生产等待,消费继续,当少于0件,消费等待,消费继续. 正常代码如下: package com.atguigu.juc; /* * 生产者和消费者案例 */ public class TestProductorAndConsumer { public static void main(String[] args) { Clerk clerk = new Clerk(); Productor pro = new Pr

pthread_cond_wait虚假唤醒

pthread_cond_wait中的while()不仅仅在等待条件变量前检查条件cond_is_false是否成立,实际上在等待条件变量后也检查条件cond_is_false是否成立.在多线程等待的情况下,这样对condition进行多做一次判断,即可避免"虚假唤醒". pthread_mutex_lock(&mutex); while(cond_is_false) pthread_cond_wait(&cond, &mutex); pthread_mutex