阅读量:84
wait() 方法是 Java 中的一个同步机制,用于让当前线程等待,直到其他线程调用同一个对象的 notify() 或 notifyAll() 方法。为了确保线程安全,你需要遵循以下几个原则:
- 同步代码块:使用
synchronized关键字来确保在同一时刻只有一个线程可以访问共享资源。你可以将需要同步的代码放在synchronized代码块中,并指定一个对象作为锁。
synchronized (lock) {
// 同步代码
}
- 使用
wait()和notify()或notifyAll():在同步代码块中,你可以使用wait()方法让当前线程等待,并在适当的时候使用notify()或notifyAll()方法唤醒等待的线程。
synchronized (lock) {
try {
lock.wait(); // 当前线程等待
} catch (InterruptedException e) {
// 处理异常
}
// 恢复执行同步代码
}
-
确保调用
wait()的线程具有对象锁:在调用wait()方法之前,确保当前线程已经获得了对象锁。否则,wait()方法将抛出IllegalMonitorStateException异常。 -
使用条件变量:在某些情况下,你可能需要更复杂的同步机制。Java 提供了
java.util.concurrent.locks包中的Condition接口和ReentrantLock类,它们提供了更灵活的线程同步机制。
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.ReentrantLock;
ReentrantLock lock = new ReentrantLock();
Condition condition = lock.newCondition();
lock.lock();
try {
condition.await(); // 当前线程等待
} catch (InterruptedException e) {
// 处理异常
}
// 恢复执行同步代码
condition.signal(); // 唤醒等待的线程
lock.unlock();
遵循以上原则,你可以确保在使用 wait() 方法时线程安全。