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