Java线程中的wait、notify和notifyAll解析

Java线程中的wait、notify和notifyAll解析顾客去包子铺买包子,告知老板自身需求后,进入等待(调用wait()方法)老板处理的过程,此时顾客的状态为WAITING,老板做好包子后,告知(调用notify()方法)顾客包子做好了。?线程间的通信的主要思想是生产者消费者机制。

大家好,又见面了,我是你们的朋友全栈君。如果您正在找激活码,请点击查看最新教程,关注关注公众号 “全栈程序员社区” 获取激活教程,可能之前旧版本教程已经失效.最新Idea2022.1教程亲测有效,一键激活。

Jetbrains全系列IDE使用 1年只要46元 售后保障 童叟无欺

Java中的线程有六种状态,具体可以查看我之前的文章:
Java中线程的6种状态详解(NEW、RUNNABLE、BLOCKED、WAITING、TIMED_WAITING、TERMINATED)。本文主要讲其中的部分状态切换。

等待唤醒案例:线程间的通信

在这里插入图片描述
顾客去包子铺买包子,告知老板自身需求后,进入等待(调用wait()方法)老板处理的过程,此时顾客的状态为
WAITING,老板做好包子后,告知(调用notify()方法)顾客包子做好了。
?线程间的通信的主要思想是生产者消费者机制。

代码实现

思路如下:

  1. 创建一个顾客线程(消费者):告知老板要的包子的种类和数量,调用wait方法,放弃CPU的执行,进入到WAITING状态(无限等待)
  2. 创建一个老板线程(生产者):花了5秒做包子,做好包子之后,调用notify方法,唤醒顾客吃包子。

代码如下:
定义一个锁对象:

//创建锁对象,保证唯一
Object obj = new Object();

创建一个顾客线程(消费者):

// 创建一个顾客线程(消费者)
new Thread(){ 
   
    @Override
    public void run() { 
   
        //一直等着买包子
        while(true){ 
   
            //保证等待和唤醒的线程只能有一个执行,需要使用同步技术
            synchronized (obj){ 
   
                System.out.println("顾客告知老板要的包子的种类和数量");
                //调用wait方法,放弃cpu的执行,进入到WAITING状态(无限等待)
                try { 
   
                    obj.wait();
                } catch (InterruptedException e) { 
   
                    e.printStackTrace();
                }
                //唤醒之后执行的代码
                System.out.println("包子已经做好了,开吃!");
                System.out.println("---------------------------------------");
            }
        }
    }
}.start();

创建一个老板线程(生产者):

//创建一个老板线程(生产者)
new Thread(){ 
   
    @Override
    public void run() { 
   
        //一直做包子
        while (true){ 
   
            //花了5秒做包子
            try { 
   
                Thread.sleep(5000);//花5秒钟做包子
            } catch (InterruptedException e) { 
   
                e.printStackTrace();
            }

            //保证等待和唤醒的线程只能有一个执行,需要使用同步技术
            synchronized (obj){ 
   
                System.out.println("老板5秒钟之后做好包子,告知顾客,可以吃包子了");
                //做好包子之后,调用notify方法,唤醒顾客吃包子
                obj.notify();
            }
        }
    }
}.start();

输出如下:

顾客告知老板要的包子的种类和数量
老板5秒钟之后做好包子,告知顾客,可以吃包子了
包子已经做好了,开吃!

?注意:
顾客和老板线程必须使用同步代码块包裹起来,保证等待和唤醒只能有一个在执行
同步使用的锁对象必须保证唯一
只有锁对象才能调用wait和notify方法。

扩展:Object类中wait带参方法和notifyAll方法

进入到TimeWaiting(计时等待)有两种方式

  1. 使用sleep(long m)方法,在毫秒值结束之后,线程睡醒进入到Runnable/Blocked状态
  2. 使用wait(long m)方法,wait方法如果在毫秒值结束之后,还没有被notify唤醒,就会自动醒来,线程睡醒进入到Runnable/Blocked状态

唤醒的方法:

  • void notify() 唤醒在此对象监视器上等待的单个线程。
  • void notifyAll() 唤醒在此对象监视器上等待的所有线程。
版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请联系我们举报,一经查实,本站将立刻删除。

发布者:全栈程序员-站长,转载请注明出处:https://javaforall.net/195924.html原文链接:https://javaforall.net

(0)
全栈程序员-站长的头像全栈程序员-站长


相关推荐

  • SpringBoot——MybatisPlus条件查询

    SpringBoot——MybatisPlus条件查询SpringBoot——MybatisPlus条件查询

    2022年4月23日
    165
  • Landsat8的不同波段组合说明

    Landsat8的不同波段组合说明原文地址:Landsat8的不同波段组合说明作者:ENVI-IDL中国   LandsatTM(ETM+)7个波段可以组合很多RGB方案用于不同地物的解译,Landsat8的OLI陆地成像仪包括9个波段,可以组合更多的RGB方案。   OLI包括了ETM+传感器所有的波段,为了避免大气吸收特征,OLI对波段进行了重新调整,比较大的调整是OLIBand5(0.845–0.885μm),

    2022年7月23日
    19
  • 无意发现web msn,很好用,呵呵[通俗易懂]

    无意发现web msn,很好用,呵呵[通俗易懂]msn不知道什么时候提供了类似QQ调用的代码像我基本就不用QQ了,msn倒是每天在线为了解决用户的问题,想了很多时时交流的办法,这回倒好直接用msn的web接口,直接时时交流了,没msn的用户也可以用

    2022年7月3日
    27
  • axios 上传文件 封装_使用axios上传文件,如何取消上传

    axios 上传文件 封装_使用axios上传文件,如何取消上传按楼上的方法,问题已决定,其实axios已经提供了方法。贴一下我自己的代码吧。//在data里声明一个sourcedata(){return{source:null,//取消上传}//上传文件letthat=this;letcancelToken=that.Axios.CancelToken;//Axios使我修改axios原型链了。that.source=cancelToken….

    2022年6月26日
    78
  • Linux文件—文件锁

    Linux文件—文件锁通过之前的open()/close()/read()/write()/lseek()函数已经可以实现文件的打开、关闭、读写等基本操作,但是这些基本操作是不够的。对于文件的操作而言,“锁定”操作是对文件(尤其是对共享文件)的一种高级的文件操作。当某进程在更新文件内数据时,期望某种机制能防止多个进程同时更新文件从而导致数据丢失,或者防止文件内容在未更新完毕时被读取并引发后续问题,这种机制就是“文件锁”。

    2022年6月28日
    51
  • R语言实现LASSO回归

    R语言实现LASSO回归Lasso回归又称为套索回归,是RobertTibshirani于1996年提出的一种新的变量选择技术。Lasso是一种收缩估计方法,其基本思想是在回归系数的绝对值之和小于一个常数的约束条件下,使残差平方和最小化,从而能够产生某些严格等于0的回归系数,进一步得到可以解释的模型。R语言中有多个包可以实现Lasso回归,这里使用lars包实现。1.利用lars函数实现lasso回归并可视化显示x…

    2022年6月11日
    28

发表回复

您的邮箱地址不会被公开。 必填项已用 * 标注

关注全栈程序员社区公众号