本文主要是介绍Java基础 浅谈线程补充 -------虚假唤醒,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!
线程虚假唤醒
提到虚假唤醒,我们需要问出两个问题,什么叫做虚假唤醒,以及虚假唤醒如何避免?
这个先不解释,也不解读,老规矩首先看代码
class Data{private int number=0;public synchronized void increment() {if(number!=0) {try {wait();} catch (InterruptedException e) {// TODO Auto-generated catch blocke.printStackTrace();}}number++;System.out.println(Thread.currentThread().getName()+"现在是number="+number);notifyAll();}public synchronized void decrement() {if(number==0) {try {this.wait();} catch (InterruptedException e) {// TODO Auto-generated catch blocke.printStackTrace();}}number--;System.out.println(Thread.currentThread().getName()+"现在是 +++number="+number);this.notifyAll();}}public class Test {public static void main(String[] args) {Data data=new Data();new Thread(()->{for(int i=0;i<10;i++) {data.increment();}} , "线程A").start() ;new Thread(()->{for (int i=0;i<10;i++){data.decrement();}},"线程b").start();}
}//输出
线程A现在是 +++number=1
线程b现在是number=0
线程A现在是 +++number=1
线程b现在是number=0
线程A现在是 +++number=1
线程b现在是number=0
线程A现在是 +++number=1
线程b现在是number=0
线程A现在是 +++number=1
线程b现在是number=0
线程A现在是 +++number=1
线程b现在是number=0
线程A现在是 +++number=1
线程b现在是number=0
线程A现在是 +++number=1
线程b现在是number=0
线程A现在是 +++number=1
线程b现在是number=0
线程A现在是 +++number=1
线程b现在是number=0
这个有事消费者和生产者的一个实例,我们看输出结果的时候,发现没有什么异常,生产者加1,消费者减1.然后依次输出结果。
这个时候我们就有一个问题了,如果两个生产者,同时生产呢,只要一个为1,那么就停止生产,等消费者取出后在生产。
class Data{private int number=0;public synchronized void increment() {if(number!=0) {try {wait();} catch (InterruptedException e) {// TODO Auto-generated catch blocke.printStackTrace();}}number++;System.out.println(Thread.currentThread().getName()+"现在是number="+number);notifyAll();}public synchronized void decrement() {if(number==0) {try {this.wait();} catch (InterruptedException e) {// TODO Auto-generated catch blocke.printStackTrace();}}number--;System.out.println(Thread.currentThread().getName()+"现在是 +++number="+number);this.notifyAll();}}public class Test {public static void main(String[] args) {Data data=new Data();new Thread(()->{for (int i=0;i<10;i++){data.decrement();}},"线程A").start();new Thread(()->{for(int i=0;i<10;i++) {data.increment();}} , "线程b").start() ;new Thread(()->{for (int i=0;i<10;i++) {data.increment();}},"线程c").start() ;}
}//输出
线程b现在是number=1
线程A现在是 +++number=0
线程b现在是number=1
线程A现在是 +++number=0
线程b现在是number=1
线程A现在是 +++number=0
线程c现在是number=1
线程b现在是number=2
线程c现在是number=3
线程A现在是 +++number=2
线程A现在是 +++number=1
线程A现在是 +++number=0
线程c现在是number=1
线程b现在是number=2
线程c现在是number=3
线程A现在是 +++number=2
线程A现在是 +++number=1
线程A现在是 +++number=0
线程c现在是number=1
线程b现在是number=2
线程c现在是number=3
线程A现在是 +++number=2
线程c现在是number=3
线程b现在是number=4
线程c现在是number=5
线程b现在是number=6
线程c现在是number=7
线程b现在是number=8
线程c现在是number=9
线程b现在是number=10
结果可能出了一些人的意料,最后number 竟然大于了1,竟然没有继续等待 毕竟if(number!=0) 等于1,应该进入等待唤醒状态的,但是现在竟然无效。为什么?
看帮助文档:
可能图片不清晰,所以我在下面在黏贴一下。
线程也可以唤醒,而不会被通知,中断或超时,即所谓的虚假唤醒 。 虽然这在实践中很少会发生,但应用程序必须通过测试应该使线程被唤醒的条件来防范,并且如果条件不满足则继续等待。 换句话说,等待应该总是出现在循环中,就像这样: synchronized (obj) {while (<condition does not hold>)obj.wait(timeout);... // Perform action appropriate to condition
可以看所谓的虚假唤醒,其实就是在程序中的判断语句有时候无法满足,所以造成的唤醒,而官方文档给出直接使用while进行避免,如果我们将if改成while然后还是两个生产者进行生产,看结果
class Data{private int number=0;public synchronized void increment() {while(number!=0) {try {wait();} catch (InterruptedException e) {// TODO Auto-generated catch blocke.printStackTrace();}}number++;System.out.println(Thread.currentThread().getName()+"现在是number="+number);notifyAll();}public synchronized void decrement() {while(number==0) {try {this.wait();} catch (InterruptedException e) {// TODO Auto-generated catch blocke.printStackTrace();}}number--;System.out.println(Thread.currentThread().getName()+"现在是 +++number="+number);this.notifyAll();}}public class Test {public static void main(String[] args) {Data data=new Data();new Thread(()->{for (int i=0;i<10;i++){data.decrement();}},"线程A").start();new Thread(()->{for(int i=0;i<10;i++) {data.increment();}} , "线程b").start() ;new Thread(()->{for (int i=0;i<10;i++) {data.increment();}},"线程c").start() ;}
}//输出
线程b现在是number=1
线程A现在是 +++number=0
线程b现在是number=1
线程A现在是 +++number=0
线程c现在是number=1
线程A现在是 +++number=0
线程b现在是number=1
线程A现在是 +++number=0
线程c现在是number=1
线程A现在是 +++number=0
线程b现在是number=1
线程A现在是 +++number=0
线程c现在是number=1
线程A现在是 +++number=0
线程b现在是number=1
线程A现在是 +++number=0
线程c现在是number=1
线程A现在是 +++number=0
线程b现在是number=1
线程A现在是 +++number=0
线程c现在是number=1
//然后程序线程会进入等待状态,然后进行等待唤醒
为什么会出现这样状态,其实根本原因就是if只会判断一次,所以会出现虚假唤醒,所以我们使用while进行避免。
当然这个也是官方文档给予的解决方式,如果暂时想不通的话,那自己暂时先记住使用while即可。
这篇关于Java基础 浅谈线程补充 -------虚假唤醒的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!