Java的wait(), notify()和notifyAll()使用心得

更新时间：2013年08月21日 14:46:00 作者：

本篇文章是对java的 wait(),notify(),notifyAll()进行了详细的分析介绍，需要的朋友参考下

wait(),notify()和notifyAll()都是java.lang.Object的方法：
wait(): Causes the current thread to wait until another thread invokes the notify() method or the notifyAll() method for this object.
notify(): Wakes up a single thread that is waiting on this object's monitor.
notifyAll(): Wakes up all threads that are waiting on this object's monitor.
这三个方法，都是Java语言提供的实现线程间阻塞(Blocking)和控制进程内调度(inter-process communication)的底层机制。在解释如何使用前，先说明一下两点：
1. 正如Java内任何对象都能成为锁(Lock)一样，任何对象也都能成为条件队列(Condition queue)。而这个对象里的wait(), notify()和notifyAll()则是这个条件队列的固有(intrinsic)的方法。
2. 一个对象的固有锁和它的固有条件队列是相关的，为了调用对象X内条件队列的方法，你必须获得对象X的锁。这是因为等待状态条件的机制和保证状态连续性的机制是紧密的结合在一起的。
(An object's intrinsic lock and its intrinsic condition queue are related: in order to call any of the condition queue methods on object X, you must hold the lock on X. This is because the mechanism for waiting for state-based conditions is necessarily tightly bound to the mechanism fo preserving state consistency)
根据上述两点，在调用wait(), notify()或notifyAll()的时候，必须先获得锁，且状态变量须由该锁保护，而固有锁对象与固有条件队列对象又是同一个对象。也就是说，要在某个对象上执行wait，notify，先必须锁定该对象，而对应的状态变量也是由该对象锁保护的。
知道怎么使用后，我们来问下面的问题：
1. 执行wait, notify时，不获得锁会如何？
请看代码：

复制代码代码如下:

public static void main(String[] args) throws InterruptedException {
        Object obj = new Object();
        obj.wait();
        obj.notifyAll();
}

执行以上代码，会抛出java.lang.IllegalMonitorStateException的异常。
2. 执行wait, notify时，不获得该对象的锁会如何？
请看代码：

复制代码代码如下:

public static void main(String[] args) throws InterruptedException {
        Object obj = new Object();
        Object lock = new Object();
        synchronized (lock) {
            obj.wait();
            obj.notifyAll();
        }
    }

执行代码，同样会抛出java.lang.IllegalMonitorStateException的异常。
3. 为什么在执行wait, notify时，必须获得该对象的锁？
这是因为，如果没有锁，wait和notify有可能会产生竞态条件(Race Condition)。考虑以下生产者和消费者的情景：
1.1生产者检查条件（如缓存满了）-> 1.2生产者必须等待
2.1消费者消费了一个单位的缓存 -> 2.2重新设置了条件（如缓存没满） -> 2.3调用notifyAll()唤醒生产者
我们希望的顺序是： 1.1->1.2->2.1->2.2->2.3
但在多线程情况下，顺序有可能是 1.1->2.1->2.2->2.3->1.2。也就是说，在生产者还没wait之前，消费者就已经notifyAll了，这样的话，生产者会一直等下去。
所以，要解决这个问题，必须在wait和notifyAll的时候，获得该对象的锁，以保证同步。
请看以下利用wait，notify实现的一个生产者、一个消费者和一个单位的缓存的简单模型：

复制代码代码如下:

public class QueueBuffer {
    int n;
    boolean valueSet = false;
    synchronized int get() {
        if (!valueSet)
            try {
                wait();
            } catch (InterruptedException e) {
                System.out.println("InterruptedException caught");
            }
        System.out.println("Got: " + n);
        valueSet = false;
        notify();
        return n;
    }
    synchronized void put(int n) {
        if (valueSet)
            try {
                wait();
            } catch (InterruptedException e) {
                System.out.println("InterruptedException caught");
            }
        this.n = n;
        valueSet = true;
        System.out.println("Put: " + n);
        notify();
    }
}

复制代码代码如下:

public class Producer implements Runnable {
    private QueueBuffer q;
    Producer(QueueBuffer q) {
        this.q = q;
        new Thread(this, "Producer").start();
    }
    public void run() {
        int i = 0;
        while (true) {
            q.put(i++);
        }
    }
}

复制代码代码如下:

public class Consumer implements Runnable {
    private QueueBuffer q;
    Consumer(QueueBuffer q) {
        this.q = q;
        new Thread(this, "Consumer").start();
    }
    public void run() {
        while (true) {
            q.get();
        }
    }
}

复制代码代码如下:

public class Main {
    public static void main(String[] args) {
        QueueBuffer q = new QueueBuffer(); 
        new Producer(q); 
        new Consumer(q); 
        System.out.println("Press Control-C to stop."); 
    }
}

所以，JVM通过在执行的时候抛出IllegalMonitorStateException的异常，来确保wait, notify时，获得了对象的锁，从而消除隐藏的Race Condition。
最后来看看一道题：写一个多线程程序，交替输出1,2,1,2,1,2......
利用wait, notify解决：

复制代码代码如下:

public class OutputThread implements Runnable {
    private int num;
    private Object lock;
    public OutputThread(int num, Object lock) {
        super();
        this.num = num;
        this.lock = lock;
    }
    public void run() {
        try {
            while(true){
                synchronized(lock){
                    lock.notifyAll();
                    lock.wait();
                    System.out.println(num);
                }
            }
        } catch (InterruptedException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
    public static void main(String[] args){
        final Object lock = new Object();
        Thread thread1 = new Thread(new OutputThread(1,lock));
        Thread thread2 = new Thread(new OutputThread(2, lock));
        thread1.start();
        thread2.start();
    }
}

您可能感兴趣的文章:

简单了解JAVA SimpleDateFormat yyyy和YYYY的区别
这篇文章主要介绍了简单了解JAVA SimpleDateFormat yyyy和YYYY的区别,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
2020-03-03
Spring Bean 依赖注入常见错误问题
这篇文章主要介绍了Spring Bean 依赖注入常见错误问题，文中提到value的工作大体分为三个核心步骤，具体内容详情跟随小编一起看看吧
2021-09-09
Java实现每日给女友微信发送早安信息
这篇文章主要为大家详细介绍了Java如何实现每日给女友微信发送早安等微信信息，文中的示例代码讲解详细，具有一定的借鉴价值，需要的可以了解一下
2022-12-12
java环境中的JDK、JVM、JRE详细介绍
这篇文章主要介绍了java环境中的JDK、JVM、JRE详细介绍的相关资料,对于初学者还是有必要了解下，细致说明他们是什么，需要的朋友可以参考下
2016-11-11
Spring中的Filter过滤器详解
这篇文章主要介绍了Spring中的Filter过滤器详解,Filter 程序是一个实现了特殊接口的 Java 类，与 Servlet 类似，也是由 Servlet 容器进行调用和执行的,需要的朋友可以参考下
2023-08-08
SpringBoot优化连接数的方法详解
SpringBoot开发最大的好处是简化配置,内置了Tomcat,下面这篇文章主要给大家介绍了关于SpringBoot优化连接数的相关资料,文中通过实例代码介绍的非常详细,需要的朋友可以参考下
2023-06-06
java 如何查看jar包加载顺序
这篇文章主要介绍了java 如何查看jar包加载顺序，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
2021-12-12
Java实战之火车票预订系统的实现
这篇文章主要介绍了利用Java实现的火车票预订系统，文中用到了JSP 、Servlert、JQuery、Ajax 等技术，文中示例代码讲解详细，需要的可以参考一下
2022-02-02
Java去除字符串中空格的方法详解
这篇文章主要介绍了Java去除字符串中空格的方法详解,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
2019-08-08
Java基础之三大控制流程结构
这篇文章主要介绍了Java基础之三大控制流程结构,文中有非常详细的代码示例,对正在学习java基础的小伙伴们有非常好的帮助,需要的朋友可以参考下
2021-04-04