写点什么

Object 中的 wait 和 notify 方法详解

作者:threedayman
  • 2023-01-30
    浙江
  • 本文字数:1682 字

    阅读完需:约 6 分钟

Object中的wait和notify方法详解

我们从一个 IllegalMonitorStateException 的处理来开始我们的讲解。


小 A 写的代码抛出了 java.lang.IllegalMonitorStateException 异常信息。


public class WaitDemo {    public static void main(String[] args) throws Exception  {        Object o = new Object();        o.wait();        //业务逻辑代码    }}
复制代码


小 A 通过查看源码,确认了抛出 IllegalMonitorStateException 异常是由于调用 wait 方法的时当前线程没有获取到调用对象的锁。


Throws:IllegalMonitorStateException – if the current thread is not the owner of the object's monitor.


根据错误原因,将代码改成如下,业务代码正常运行。


public class WaitDemo {    public static void main(String[] args) throws Exception  {        Object o = new Object();        synchronized (o){            o.wait();        }        //业务逻辑代码    }}
复制代码


通过这个异常的处理小 A 认识到自己对于 wait 和 notify 方法缺乏足够的了解,导致了异常的发生,下面我们一起来学习下 wait 和 notify 方法

wait 和 notify 方法介绍

wait 和 notify 是 Object 类中定义的方法。调用这两个方法的前提条件:当前线程拥有调用者的锁。


wait 方法有好几个重载方法,但最终都调用了如下的 wait 本地方法。调用 wait 方法后,当前线程会进入 waiting 状态直到其他线程调用此对象的 notify、notifyAll 方法或者指定的等待时间过去。


public final native void wait(long timeout) throws InterruptedException;
复制代码


notify 和 notifyAll 方法,两者的区别是 notify 方法唤醒一个等待在调用对象上的线程,notifyAll 方法唤醒所有的等待在调用对象上的线程。


那么唤醒后的线程是否就可以直接执行了? 答案是否定的。唤醒后的线程需要获取到调用对象的锁后才能继续执行。


public final native void notify();
复制代码


public final native void notifyAll();
复制代码

使用场景和代码样例

wait 和 notify 方法可以在多线程的通知场景下使用,比如对于共享变量 count,写线程和读线程交替的写和读。如下面代码所示。


package org.example;
public class WaitDemo { private static int count = 0; private static Object o = new Object(); public static void main(String[] args) throws InterruptedException { Write w = new Write(); Read r = new Read(); w.start(); //为了保证写线程先获取到对象锁 Thread.sleep(1000); r.start(); } static class Write extends Thread{ @Override public void run(){ while(true){ synchronized (o){ o.notify(); count++; try { Thread.sleep(100); o.wait(); } catch (InterruptedException e) { e.printStackTrace(); } } }
} }
static class Read extends Thread{ @Override public void run(){ while(true){ synchronized (o){ System.out.println(count); o.notify(); try { Thread.sleep(100); o.wait(); } catch (InterruptedException e) { e.printStackTrace(); } } }
}
}}
复制代码


运行以上代码结果如下图


1234567891011121314151617181920212223
复制代码


符合我们的预期,按照顺序输出了 count 的值。

总结

使用 wait 和 notify 方法有以下注意点


  • 调用 wait 和 notify 方法时需要获取到调用对象的锁(monitor)。

  • 调用 wait 方法后,当前线程进入 waitting 状态并释放锁。

  • 等待线程被 notify 唤醒后,需要或许到调用对象的锁(monitor)后才能继续执行业务逻辑。

用户头像

threedayman

关注

还未添加个人签名 2019-02-19 加入

还未添加个人简介

评论

发布
暂无评论
Object中的wait和notify方法详解_面试_threedayman_InfoQ写作社区