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()
方法时线程安全。