JavanotifyAll唤醒线程详解

**Java中notifyAll唤醒线程方法详解：** `notifyAll()`是Java并发编程中用于唤醒等待线程的关键方法。本文深入解析`notifyAll()`的工作机制及使用方法，尤其是在多线程环境下的线程协作。`notifyAll()`必须在`synchronized`块中调用，并配合`wait()`方法，实现线程间的有效通信。文章通过生产者-消费者模型的示例，详细展示了如何利用`notifyAll()`唤醒所有等待特定对象监视器的线程，避免线程阻塞，确保程序的正确性和效率。此外，本文还强调了使用`notifyAll()`的关键注意事项，例如必须在`synchronized`块中调用，以及使用`while`循环处理虚假唤醒，助你掌握`notifyAll()`的精髓，提升并发编程能力。

notifyAll()用于唤醒所有等待特定对象监视器的线程，需在synchronized块中调用，配合wait()实现线程协作，如生产者-消费者模型中通过notifyAll()确保多个消费者或生产者被唤醒，避免线程阻塞。

在Java中，notifyAll() 用于唤醒所有正在等待特定对象监视器的线程。它通常与 synchronized 块、wait() 方法配合使用，实现线程间的协作。下面介绍如何正确使用 notifyAll() 来唤醒线程。

1. 理解 wait() 和 notifyAll() 的工作机制

这三个方法都定义在 Object 类中，必须在 synchronized 上下文中调用：

• wait()：使当前线程释放锁并进入等待状态，直到被唤醒。
• notify()：随机唤醒一个等待该对象锁的线程。
• notifyAll()：唤醒所有等待该对象锁的线程，这些线程将重新竞争获取锁。

2. 使用步骤和代码示例

以下是一个生产者-消费者模型的简单示例，展示如何用 notifyAll() 正确唤醒多个等待线程：

import java.util.LinkedList;
import java.util.Queue;

public class NotifyAllExample {
    private final Queue queue = new LinkedList<>();
    private final int MAX_SIZE = 3;

    public void produce(String item) throws InterruptedException {
        synchronized (this) {
            while (queue.size() == MAX_SIZE) {
                System.out.println("队列已满，生产者等待...");
                this.wait(); // 释放锁并等待
            }
            queue.add(item);
            System.out.println("生产了: " + item);
            this.notifyAll(); // 唤醒所有等待线程（包括消费者）
        }
    }

    public String consume() throws InterruptedException {
        synchronized (this) {
            while (queue.isEmpty()) {
                System.out.println("队列为空，消费者等待...");
                this.wait(); // 释放锁并等待
            }
            String item = queue.poll();
            System.out.println("消费了: " + item);
            this.notifyAll(); // 唤醒所有等待线程（包括生产者）
            return item;
        }
    }
}

3. 多线程测试 notifyAll 的效果

启动多个生产者和消费者线程，观察 notifyAll 如何唤醒多个等待线程：

public class TestNotifyAll {
    public static void main(String[] args) {
        NotifyAllExample example = new NotifyAllExample();

        // 启动多个消费者线程
        for (int i = 1; i <= 3; i++) {
            new Thread(() -> {
                try {
                    while (true) {
                        example.consume();
                        Thread.sleep(2000); // 模拟处理时间
                    }
                } catch (InterruptedException e) {
                    Thread.currentThread().interrupt();
                }
            }, "Consumer-" + i).start();
        }

        // 启动生产者线程
        new Thread(() -> {
            int counter = 1;
            try {
                while (true) {
                    example.produce("item-" + counter++);
                    Thread.sleep(500);
                }
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
            }
        }, "Producer").start();
    }
}

4. 关键注意事项

使用 notifyAll() 时需注意以下几点：

• 始终在 synchronized 块或方法中调用 wait() 和 notifyAll()。
• 使用 while 而不是 if 判断等待条件，防止虚假唤醒或条件变化后继续执行。
• notifyAll() 会唤醒所有等待线程，但它们需要重新竞争锁，只有一个能进入同步块。
• 适合场景：当多个线程可能等待同一条件时（如多个消费者），notifyAll() 更安全。

基本上就这些。notifyAll() 是实现线程协作的重要工具，合理使用可避免死锁和线程饥饿问题。

文中关于的知识介绍，希望对你的学习有所帮助！若是受益匪浅，那就动动鼠标收藏这篇《JavanotifyAll唤醒线程详解》文章吧，也可关注golang学习网公众号了解相关技术文章。