Java基础 浅谈线程补充 -------虚假唤醒

2024-06-18 21:38

本文主要是介绍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基础 浅谈线程补充 -------虚假唤醒的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1073128

相关文章

python panda库从基础到高级操作分析

《pythonpanda库从基础到高级操作分析》本文介绍了Pandas库的核心功能,包括处理结构化数据的Series和DataFrame数据结构,数据读取、清洗、分组聚合、合并、时间序列分析及大数据... 目录1. Pandas 概述2. 基本操作:数据读取与查看3. 索引操作:精准定位数据4. Group

Spring Boot集成/输出/日志级别控制/持久化开发实践

《SpringBoot集成/输出/日志级别控制/持久化开发实践》SpringBoot默认集成Logback,支持灵活日志级别配置(INFO/DEBUG等),输出包含时间戳、级别、类名等信息,并可通过... 目录一、日志概述1.1、Spring Boot日志简介1.2、日志框架与默认配置1.3、日志的核心作用

破茧 JDBC:MyBatis 在 Spring Boot 中的轻量实践指南

《破茧JDBC:MyBatis在SpringBoot中的轻量实践指南》MyBatis是持久层框架,简化JDBC开发,通过接口+XML/注解实现数据访问,动态代理生成实现类,支持增删改查及参数... 目录一、什么是 MyBATis二、 MyBatis 入门2.1、创建项目2.2、配置数据库连接字符串2.3、入

Springboot项目启动失败提示找不到dao类的解决

《Springboot项目启动失败提示找不到dao类的解决》SpringBoot启动失败,因ProductServiceImpl未正确注入ProductDao,原因:Dao未注册为Bean,解决:在启... 目录错误描述原因解决方法总结***************************APPLICA编

深度解析Spring Security 中的 SecurityFilterChain核心功能

《深度解析SpringSecurity中的SecurityFilterChain核心功能》SecurityFilterChain通过组件化配置、类型安全路径匹配、多链协同三大特性,重构了Spri... 目录Spring Security 中的SecurityFilterChain深度解析一、Security

SpringBoot多环境配置数据读取方式

《SpringBoot多环境配置数据读取方式》SpringBoot通过环境隔离机制,支持properties/yaml/yml多格式配置,结合@Value、Environment和@Configura... 目录一、多环境配置的核心思路二、3种配置文件格式详解2.1 properties格式(传统格式)1.

Apache Ignite 与 Spring Boot 集成详细指南

《ApacheIgnite与SpringBoot集成详细指南》ApacheIgnite官方指南详解如何通过SpringBootStarter扩展实现自动配置,支持厚/轻客户端模式,简化Ign... 目录 一、背景:为什么需要这个集成? 二、两种集成方式(对应两种客户端模型) 三、方式一:自动配置 Thick

Spring WebClient从入门到精通

《SpringWebClient从入门到精通》本文详解SpringWebClient非阻塞响应式特性及优势,涵盖核心API、实战应用与性能优化,对比RestTemplate,为微服务通信提供高效解决... 目录一、WebClient 概述1.1 为什么选择 WebClient?1.2 WebClient 与

Java.lang.InterruptedException被中止异常的原因及解决方案

《Java.lang.InterruptedException被中止异常的原因及解决方案》Java.lang.InterruptedException是线程被中断时抛出的异常,用于协作停止执行,常见于... 目录报错问题报错原因解决方法Java.lang.InterruptedException 是 Jav

深入浅出SpringBoot WebSocket构建实时应用全面指南

《深入浅出SpringBootWebSocket构建实时应用全面指南》WebSocket是一种在单个TCP连接上进行全双工通信的协议,这篇文章主要为大家详细介绍了SpringBoot如何集成WebS... 目录前言为什么需要 WebSocketWebSocket 是什么Spring Boot 如何简化 We