Java中线程等待唤醒通过wait()、notify()、notifyAll()实现,必须在synchronized中调用;wait()使线程释放锁并等待,notify()随机唤醒一个线程,notifyAll()唤醒所有线程;被唤醒线程需重新竞争锁;应使用while循环防止虚假唤醒;生产者-消费者模型是典型应用;也可用Lock配合Condition实现更灵活控制。

Java中实现线程的等待与唤醒机制主要依赖于Object类提供的wait()、notify()和notifyAll()方法。这些方法必须在同步上下文中使用,也就是必须在synchronized代码块或方法中调用,否则会抛出IllegalMonitorStateException。
1. wait() 方法:使线程等待
当一个线程执行到wait()方法时,它会释放当前持有的对象锁,并进入该对象的等待队列,直到被其他线程唤醒。
-
wait():无限等待,直到被唤醒 -
wait(long timeout):最多等待指定毫秒数 -
wait(long timeout, int nanos):更精确的时间控制(较少使用)
2. notify() 和 notifyAll():唤醒等待的线程
notify()会随机唤醒一个在该对象上等待的线程,而notifyAll()会唤醒所有在该对象上等待的线程。被唤醒的线程需要重新竞争对象锁,获得锁后才能继续执行。
注意:
立即学习“Java免费学习笔记(深入)”;
- 只有持有对象锁的线程才能调用这些方法
- 被唤醒的线程不会立即执行,必须重新获取锁
- 建议使用while循环检查条件,避免虚假唤醒
3. 实际示例:生产者-消费者模型
下面是一个简单的生产者消费者例子,展示等待唤醒机制的实际应用:
class SharedResource {
private int data;
private boolean hasData = false;
public synchronized void produce(int value) throws InterruptedException {
while (hasData) {
// 如果已有数据,生产者等待
wait();
}
data = value;
hasData = true;
System.out.println("生产了: " + data);
notify(); // 唤醒消费者
}
public synchronized void consume() throws InterruptedException {
while (!hasData) {
// 如果没有数据,消费者等待
wait();
}
System.out.println("消费了: " + data);
hasData = false;
notify(); // 唤醒生产者
}
}在这个例子中,生产者和消费者通过共享资源的对象锁进行协调,利用wait()和notify()实现线程间的通信。
4. 使用Lock和Condition的替代方案
从Java 5开始,也可以使用java.util.concurrent.locks.Lock配合Condition来实现更灵活的等待唤醒机制:
import java.util.concurrent.locks.*;
Lock lock = new ReentrantLock();
Condition condition = lock.newCondition();
lock.lock();
try {
while (!conditionMet) {
condition.await(); // 等待
}
// 执行操作
condition.signal(); // 或 signalAll()
} finally {
lock.unlock();
}这种方式比传统的synchronized更灵活,支持多个等待队列、可中断等待、超时等待等高级特性。
基本上就这些。核心是理解对象监视器、锁的释放与获取,以及正确使用循环判断条件。










