42 notify()和 notifyAll()有什么区别？

Posted 2021-02-20 ynzj123

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了42 notify()和 notifyAll()有什么区别？相关的知识，希望对你有一定的参考价值。

notify()和 notifyAll()有什么区别？

答：

两概念：Java中的等待池、锁池。

等待池:假设一个线程A调用了某个对象的wait()方法，线程A就会释放该对象的锁后，进入到了该对象的等待池中。等待池中的线程不会去竞争该对象的锁。
锁池:只有获取了对象的锁，线程才能执行对象的 synchronized 代码，对象的锁每次只有一个线程可以获得，其他线程只能在锁池中等待。

java中的锁池和等待池，地址

notify、notifyAll 的区别

如果线程调用了对象的 wait()方法，那么线程便会处于该对象的等待池中，等待池中的线程不会去竞争该对象的锁。
当有线程调用了对象的 notifyAll()方法（唤醒所有 wait 线程）或 notify()方法（只随机唤醒一个 wait 线程），被唤醒的的线程便会进入该对象的锁池中，锁池中的线程会去竞争该对象锁。也就是说，调用了notify后只要一个线程会由等待池进入锁池，而notifyAll会将该对象等待池内的所有线程移动到锁池中，等待锁竞争。
优先级高的线程竞争到对象锁的概率大，假若某线程没有竞争到该对象锁，它还会留在锁池中，唯有线程再次调用 wait()方法，它才会重新回到等待池中。而竞争到对象锁的线程则继续往下执行，直到执行完了 synchronized 代码块，它会释放掉该对象锁，这时锁池中的线程会继续竞争该对象锁。

线程间协作：wait、notify、notifyAll，地址

综上，唤醒线程，另一种解释可以说是将线程由等待池移动到锁池，notifyAll调用后，会将全部线程由等待池移到锁池，然后参与锁的竞争，竞争成功则继续执行，如果不成功则留在锁池等待锁被释放后再次参与竞争。而notify只会唤醒一个线程。

所以，notify可能会导致死锁，而notifyAll则不会就很好解释。

原文链接： https://my.oschina.net/wxiwei/blog/1560818/print （概念）
原文链接： https://www.cnblogs.com/ConstXiong/p/12009144.html （拓展）

拓展：

测试代码

public class TestNotifyNotifyAll {
 
    private static Object obj = new Object();
    
    public static void main(String[] args) {
        
        //测试 RunnableImplA wait()        
        Thread t1 = new Thread(new RunnableImplA(obj));
        Thread t2 = new Thread(new RunnableImplA(obj));
        t1.start();
        t2.start();
        
        //RunnableImplB notify()
        Thread t3 = new Thread(new RunnableImplB(obj));
        t3.start();
        
        
//        //RunnableImplC notifyAll()
//        Thread t4 = new Thread(new RunnableImplC(obj));
//        t4.start();
    }
    
}
 
 
class RunnableImplA implements Runnable {
 
    private Object obj;
    
    public RunnableImplA(Object obj) {
        this.obj = obj;
    }
    
    public void run() {
        System.out.println("run on RunnableImplA");
        synchronized (obj) {
            System.out.println("obj to wait on RunnableImplA");
            try {
                obj.wait();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println("obj continue to run on RunnableImplA");
        }
    }
}
 
class RunnableImplB implements Runnable {
 
    private Object obj;
    
    public RunnableImplB(Object obj) {
        this.obj = obj;
    }
    
    public void run() {
        System.out.println("run on RunnableImplB");
        System.out.println("睡眠3秒...");
        try {
            Thread.sleep(3000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        synchronized (obj) {
            System.out.println("notify obj on RunnableImplB");
            obj.notify();
        }
    }
}
 
class RunnableImplC implements Runnable {
 
    private Object obj;
    
    public RunnableImplC(Object obj) {
        this.obj = obj;
    }
    
    public void run() {
        System.out.println("run on RunnableImplC");
        System.out.println("睡眠3秒...");
        try {
            Thread.sleep(3000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        synchronized (obj) {
            System.out.println("notifyAll obj on RunnableImplC");
            obj.notifyAll();
        }
    }
}

结果：仅调用一次 obj.notify()，线程 t1 或 t2 中的一个始终在等待被唤醒，程序不终止

run on RunnableImplA

obj to wait on RunnableImplA

run on RunnableImplA

obj to wait on RunnableImplA

run on RunnableImplB

睡眠3秒...

notify obj on RunnableImplB

obj continue to run on RunnableImplA
?

把 t3 注掉，启动 t4 线程。调用 obj.notifyAll() 方法

public class TestNotifyNotifyAll {
 
    private static Object obj = new Object();
    
    public static void main(String[] args) {
        
        //测试 RunnableImplA wait()        
        Thread t1 = new Thread(new RunnableImplA(obj));
        Thread t2 = new Thread(new RunnableImplA(obj));
        t1.start();
        t2.start();
        
//        //RunnableImplB notify()
//        Thread t3 = new Thread(new RunnableImplB(obj));
//        t3.start();
        
        
        //RunnableImplC notifyAll()
        Thread t4 = new Thread(new RunnableImplC(obj));
        t4.start();
    }
    
}