问题描述
请注意,这不是实际情况。我根据我的实际实现创建了一个示例场景,以便于查看。我也已经得到了预期的输出。但是,我需要澄清一些有关 Java 中 wait()
和 notifyAll()
方法的概念。 (在这里,这两个线程都会在主线程中同时启动 run 方法。)所以据我所知,由于线程 B 正在休眠,因为您可以在初始阶段看到 reamingCount 为 400。
所以线程 B 将调用它的 MUTEX.wait()
并继续它的睡眠,直到某个其他线程调用 notify()
或 notifyAll()
,然后在剩余计数递减为 0 后,线程 A 将调用 {{ 1}} 唤醒线程 B 和 MUTEX.notifyAll();
释放其已经授予的锁,并进入休眠状态,直到线程 B 通知它。
当我通过线程 A 调用 MUTEX.wait()
时,线程 B 不会在线程 A 调用 MUTEX.notifyAll()
之前唤醒并继续执行任务吗?
我的意思是,您可以看到当线程 A 调用 MUTEX.wait()
时,线程 B 将唤醒并再次检查 while 循环中的条件是真还是假。因此,由于剩余计数等于 0,线程 B 将退出 while 循环并在线程 A 调用 MUTEX.notifyAll()
之前继续其任务。这种情况不会破坏wait()
的原则吗?据我所知,线程 B 只能在线程 A 调用 wait()
时继续执行。
wait()
public class A implements Runnable{
public static volatile remainingCount =400;
private final Object MUTEX;//Both class A and B holds the same object mutex
private void methodA(){
synchronized(MUTEX){
while(remainingCount == 0){
MUTEX.notifyAll();
MUTEX.wait();
}
//Perform it's usual task.In here remaining count will decrement during the process.
}
@Override
public void run() {
while(true){
methodA();
}
}
}
}
解决方法
当持有锁的线程对锁定的对象调用 wait()
时,该线程被添加到对象的等待集中并释放锁。
当持有锁的线程调用notify()
,并且等待集合不为空时,等待集合中的一个线程被选中并移除。同样,调用 notifyAll()
会从等待集中删除所有线程。
注意:也可以通过调用 thread.interrupt()
从等待集中删除线程。
当一个线程从等待集中移除并开始运行时,第一步是重新获取锁。这发生在从 wait()
返回之前。
在调用 notify()
或 notifyAll()
的线程通过调用 wait()
或退出同步块释放锁之前,不会发生这种情况。
因此,虽然您的线程 B 已启用运行,但在线程 A 通过调用 wait()
释放锁之前,它实际上不会从 MUTEX.wait()
返回。同样,线程 A 可以在 B 调用 MUTEX.notifyAll()
时运行,但不会从 wait()
返回,直到线程 B 退出 synchronized(MUTEX)
块。