Java并发编程中等待唤醒机制解析-java教程-PHP中文网

Java并发编程中等待唤醒机制解析

P粉602998670

发布： 2025-09-27 19:05:01

原创

538人浏览过

等待唤醒机制通过wait()、notify()、notifyAll()实现线程通信，需在synchronized中使用，确保线程安全；生产者-消费者模型用while循环防止虚假唤醒；相比synchronized，Lock配合Condition更灵活，支持多条件队列，提升并发控制精度。

java并发编程中等待唤醒机制解析

在Java并发编程中，线程之间的协调是关键问题之一。等待唤醒机制是实现线程间通信的重要手段，它允许某些线程在特定条件未满足时进入等待状态，由其他线程在条件达成后将其唤醒。这种机制主要依赖于Object类提供的wait()、notify()和notifyAll()方法，结合synchronized关键字使用，确保线程安全与正确协作。

wait()、notify() 和 notifyAll() 的基本用法

这三个方法定义在Object类中，任何对象都可以调用它们，但必须在同步块或同步方法中执行，否则会抛出IllegalMonitorStateException。

wait()：当前线程释放锁并进入对象的等待队列，直到被唤醒或中断。
notify()：随机唤醒一个在该对象上等待的线程，使其重新竞争锁。
notifyAll()：唤醒所有在该对象上等待的线程，由JVM选择哪个线程先获取锁。

注意：wait()调用后线程会释放持有的监视器锁，而从等待中被唤醒后需重新获取锁才能继续执行。

经典生产者-消费者模型示例

通过一个简单的缓冲区模型展示等待唤醒机制的实际应用：

立即进入“豆包AI人工智官网入口”；

立即学习“豆包AI人工智能在线问答入口”；

豆包AI编程

豆包推出的AI编程助手

483

查看详情

class Buffer {
    private int data = -1;
    private boolean isEmpty = true;

    public synchronized void produce(int value) {
        while (!isEmpty) {
            try {
                wait(); // 缓冲区非空，生产者等待
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
            }
        }
        data = value;
        isEmpty = false;
        notifyAll(); // 唤醒消费者
    }

    public synchronized int consume() {
        while (isEmpty) {
            try {
                wait(); // 缓冲区为空，消费者等待
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
            }
        }
        isEmpty = true;
        notifyAll(); // 唤醒生产者
        return data;
    }
}

登录后复制

这里使用while循环而非if判断，是为了防止虚假唤醒（spurious wakeup）导致逻辑错误。只有当条件真正满足时，线程才应继续执行。

与Lock和Condition的对比

JDK 5引入了java.util.concurrent.locks包，提供了更灵活的替代方案。使用ReentrantLock配合Condition对象可以实现更精确的控制：

一个Lock可以创建多个Condition实例，实现不同条件的独立等待与唤醒。
Condition的await()、signal()、signalAll()方法功能类似于wait()、notify()、notifyAll()，但更加面向对象且支持中断响应。
避免了内置锁只能绑定单一等待/通知队列的局限性。