wait、notify、notifyAll的阻塞和恢复

简介:

(一)准备

  按照惯例应该是要先介绍一下wait、notify和notifyAll的基础知识。我找到了一篇不错的文章:《Java的wait(), notify()和notifyAll()使用小结》,它甚至介绍了为什么wait等方法为什么必须先获得对象锁。在这里我就不重复说了。

(二)阻塞和恢复

(1)wait方法

  wait方法继承自Object类(方法修饰符为fianl native,这也解释了为什么condition类中不能重写wait等方法),一共有三个方法:

复制代码
复制代码
public final void wait(long timeout) 
                throws InterruptedException public final void wait(long timeout, int nanos) throws InterruptedException public final void wait() throws InterruptedException
复制代码
复制代码

  阻塞:这三个方法的调用都会使当前线程阻塞。该线程将会被放置到对该Object的请求等待队列中,然后让出当前对Object所拥有的所有的同步请求。线程会一直暂停所有线程调度,直到下面其中一种情况发生:

    ① 其他线程调用了该Object的notify方法,而该线程刚好是那个被唤醒的线程;

    ② 其他线程调用了该Object的notifyAll方法;

    ③ 其他对象中断/杀死了该线程;

    ④ (这种情况,只针对前两个方法)线程在等待指定的时间后;

  恢复:线程将会从等待队列中移除,重新成为可调度线程。它会与其他线程以常规的方式竞争对象同步请求。一旦它重新获得对象的同步请求,所有之前的请求状态都会恢复,也就是线程调用wait的地方的状态。线程将会在之前调用wait的地方继续运行下去。

(2)notify和notifyAll方法

  notify的作用就是唤醒请求队列中的一个线程,而notifyAll唤醒的是请求队列中的所有线程。

  被唤醒的线程不会马上运行,除非获取了该Object的锁。也就是说,调用notify的线程,在调用notify后,不会像wait一样,马上阻塞线程的运行。而是继续运行,直到相应的线程调度完成或者让出Object的锁。而被唤醒的线程会在当前线程让出Object锁后,与其他线程以常规的方式竞争对象锁(正如上面提到的)。

 

参考资料:

https://docs.oracle.com/javase/7/docs/api/java/lang/Object.html

复制代码
public class WaitNotifyDemo {
    private volatile int val = 1;
    private Object o1= new Object();
    private Object o2= new Object();

    public class PrinterA implements Runnable {
        public void run() {
            while (val <= 3) {
                synchronized (o2) {
                    try {
                        System.out.println("222222222");
                        o2.wait();
                        System.out.println("111111111");
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
            }
        }
    }
    public class PrinterC implements Runnable {
        public void run() {
            while (val <= 3) {
                synchronized (o2) {
                    try {
                        System.out.println("4444");
                        o2.wait();
                        System.out.println("3333");
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
            }
        }
    }
    public class PrinterB implements Runnable {
        public void run() {
            while (val <= 30000) {
                synchronized (o2) {
                    o2.notify();
//                    o2.notifyAll();
                }
            }
        }
    }
    public static void main(String[] args) {
        WaitNotifyDemo demo = new WaitNotifyDemo();
        demo.doPrint();
    }

    private void doPrint() {
        PrinterA pa = new PrinterA();
        Thread a = new Thread(pa);
        a.setName("printerA");
        a.start();
        PrinterC pc = new PrinterC();
        Thread c = new Thread(pc);
        c.setName("printerC");
        c.start();
        PrinterB pB = new PrinterB();
        Thread b = new Thread(pB);
        b.setName("printerA");
        b.start();
    }
}
复制代码

 



本文转自农夫山泉别墅博客园博客,原文链接:http://www.cnblogs.com/yaowen/p/6141807.html,如需转载请自行联系原作者

相关文章
|
4月前
|
Java
线程间通信之Object.wait/notify实现
线程间通信之Object.wait/notify实现
28 0
|
4月前
|
调度
多线程之wait&notify
多线程之wait&notify
|
10月前
多线程之——wait/notify
多线程之——wait/notify
43 0
|
算法 Java 程序员
Java多线程之死锁问题,wait和notify
Java多线程之死锁问题,wait和notify
188 0
Java多线程之死锁问题,wait和notify
|
Java
Java线程中的wait、notify和notifyAll解析
Java线程中的wait、notify和notifyAll解析
94 1
|
Java 调度 开发者
线程 - 你真的懂 wait、notify、notifyAll 吗?
线程 - 你真的懂 wait、notify、notifyAll 吗?
97 0
线程 - wait & sleep 区别
线程 - wait & sleep 区别
90 0
wait 和 notify 有坑。。
也许我们只知道wait和notify是实现线程通信的,同时要使用synchronized包住,其实在开发中知道这个是远远不够的。接下来看看两个常见的问题。