java · 2019-07-27 0

Java中的wait()、notify()和notifyAll()方法

一、wait()、notify()和notifyAll()方法

wait():当前线程进入阻塞状态,并释放同步锁

notify():唤醒被wait的一个线程,如果多个线程被wait,就会唤醒优先级最高的那个线程

notifyAll():唤醒所有被wait的方法

这三个方法是Object类的方法;必须使用在同步代码块中或同步方法中;调用者必须是同步代码块或同步方法的同步监视器。

因为同步监视器可以为任意对象,所以理解java设计者把这三个方法为Object类方法。

二、示例代码

两个线程交替打印1-10,执行顺序:

  1. 当线程1进行number++后,wait()进入阻塞状态,释放同步锁
  2. 线程2则执行到synchronized拿到同步锁,notify唤醒线程1,此时,线程2有同步锁,线程1没有同步锁,线程1是等待状态
  3. 线程2进行number++后,wait()进入阻塞状态,释放同步锁,线程1获得同步锁,线程1继续执行

从而实现两个线程交替打印的效果

//当然可以使用任何对象作为同步监视器,则调用wait()和notify()为此同步监视器
class Number implements Runnable{

    private int number = 1;

    @Override
    public void run() {
        while (true){
//            this是当前对象
            synchronized (this) {
//                唤醒被阻塞的线程
                this.notify();
                if (number <= 10){
                    System.out.println(Thread.currentThread().getName() + ":" + number);
                    number++;
                    try {
//                        当前线程进入阻塞状态,并释放同步锁
                        this.wait();
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }else {
                    break;
                }
            }
        }
    }

}

public class CommunicationTest {

    public static void main(String[] args) {
        Number number = new Number();
        Thread t1 = new Thread(number, "线程1");
        Thread t2 = new Thread(number, "线程2");

        t1.start();
        t2.start();
    }

}

结果:

result