在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()方法时,务必确保在循环中调用它,以防止虚假唤醒。