我们从一个 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();
}
}
}
}
}
}
复制代码
运行以上代码结果如下图
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
复制代码
符合我们的预期,按照顺序输出了 count 的值。
总结
使用 wait 和 notify 方法有以下注意点
调用 wait 和 notify 方法时需要获取到调用对象的锁(monitor)。
调用 wait 方法后,当前线程进入 waitting 状态并释放锁。
等待线程被 notify 唤醒后,需要或许到调用对象的锁(monitor)后才能继续执行业务逻辑。
评论