在Java中,wait()
方法是Object
类的一个方法,用于让当前线程等待,直到其他线程调用同一个对象的notify()
或notifyAll()
方法。wait()
方法通常与synchronized
关键字和Lock
接口一起使用,以实现线程间的状态同步。
以下是使用wait()
方法进行状态同步的步骤:
synchronized
:为了确保在同一时间只有一个线程可以访问共享资源,需要将对象声明为synchronized
。这样,当一个线程进入synchronized
代码块时,其他线程将被阻塞,直到当前线程释放锁。public synchronized void waitForState() throws InterruptedException {
// 等待状态同步的代码
}
或者使用Lock
接口:
private final Lock lock = new ReentrantLock();
public void waitForState() throws InterruptedException {
lock.lock(); // 获取锁
try {
// 等待状态同步的代码
} finally {
lock.unlock(); // 释放锁
}
}
wait()
方法:在synchronized
代码块或Lock
的try
块中,调用wait()
方法让当前线程等待。wait()
方法需要在一个循环中调用,以防止虚假唤醒。public synchronized void waitForState() throws InterruptedException {
while (!state) { // 当状态不为所需状态时,继续等待
wait(); // 等待其他线程调用notify()或notifyAll()方法
}
}
或者使用Lock
接口:
public void waitForState() throws InterruptedException {
lock.lock(); // 获取锁
try {
while (!state) { // 当状态不为所需状态时,继续等待
lock.wait(); // 等待其他线程调用notify()或notifyAll()方法
}
} finally {
lock.unlock(); // 释放锁
}
}
notify()
或notifyAll()
方法:当其他线程改变了共享资源的状态,需要调用notify()
或notifyAll()
方法唤醒等待的线程。notify()
方法只唤醒一个等待的线程,而notifyAll()
方法会唤醒所有等待的线程。public synchronized void changeState() {
state = true; // 改变状态
notify(); // 唤醒一个等待的线程
}
或者使用Lock
接口:
public void changeState() {
lock.lock(); // 获取锁
try {
state = true; // 改变状态
lock.notify(); // 唤醒一个等待的线程
} finally {
lock.unlock(); // 释放锁
}
}
通过以上步骤,可以使用wait()
方法实现线程间的状态同步。请注意,在使用wait()
方法时,务必确保在循环中调用它,以防止虚假唤醒。