Java Object 的 notify() 方法

爱被打了一巴掌 2021-09-21 10:04 288阅读 0赞

我们都知道Java Object 中的 wait() 和 notify() 方法可以进行线程间的通信。

wait() 方法： 当前线程释放对象锁(监视器)的拥有权，在其他线程调用此对象的 notify() 方法或 notifyAll() 方法前，当前线程处于等待状态。

notify() 方法：唤醒在此对象锁(监视器)上等待的单个线程。如果有多个线程都在此对象上等待，则会选择唤醒其中一个线程。选择是任意性的，并且根据实现进行选择。

这里说的一点就是，**调用当前线程 noitfy() 后，等待的获取对象锁的其他线程(可能有多个)不会立即从 wait() 处返回，而是需要调用 notify() 的当前线程释放锁（退出同步块）之后，等待线程才有机会从 wait() 返回**。这点自己之前理解得不清晰，举个例子加深一下：

**等待线程**：

public class WaitThread implements Runnable{
        Object lock;
    
        public WaitThread(Object lock){
            this.lock = lock;
        }
    
        public void run() {
            String threadName = Thread.currentThread().getName();
            synchronized (lock){
                System.out.println(threadName + "开始进入同步代码块区域");
                try {
                    lock.wait();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                System.out.println(threadName + "准备离开同步代码块区域");
            }
        }
    }

**唤醒线程**：

public class NotifyThread implements Runnable{
    
        Object lock;
    
        public NotifyThread(Object lock){
            this.lock = lock;
        }
    
        public void run() {
            String threadName = Thread.currentThread().getName();
            synchronized (lock){
                System.out.println(threadName + "开始进入同步代码块区域");
                lock.notify();
                try {
                    System.out.println(threadName + "业务处理开始");
                    // 暂停 2s 表示业务处理
                    Thread.sleep(2000);
                    System.out.println(threadName + "业务处理结束");
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                System.out.println(threadName + "准备离开同步代码块区域");
                //lock.notify();放在这一行唤醒，效果一样
            }
            try {
                Thread.sleep(5000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println(threadName + "退出同步代码块后续操作");
        }
    }

注意：lock.notify() 的位置和放在注释的位置，效果一样的，线程都会在执行完synchronized同步代码块之后才会释放锁，其他处于 wait() 线程才有可能被唤醒。

**主程序**：

public class Test {
        public static void main(String[] args) throws InterruptedException {
            Object lock = new Object();
            Thread waitThread = new Thread(new WaitThread(lock), "waitThread");
            Thread notifyThread = new Thread(new NotifyThread(lock), "notifyThread");
            waitThread.start();
            Thread.sleep(1000);
            notifyThread.start();
        }
    }

**输出结果**：

waitThread开始进入同步代码块区域
    notifyThread开始进入同步代码块区域
    notifyThread业务处理开始
    notifyThread业务处理结束
    notifyThread准备离开同步代码块区域
    waitThread准备离开同步代码块区域
    notifyThread退出同步代码块后续操作

可以看到waitThread线程必须等到notifyThread线程退出同步块释放锁之后，才会从 wait() 处返回。lock.notify() 放在注释掉的那一行，输出结果不变。不过在平常工作中，还是建议把 notify() 放在容易理解的位置。