Java 中wait() 和notifyAll() 的行为?

问题描述

请注意,这不是实际情况。我根据我的实际实现创建了一个示例场景,以便于查看。我也已经得到了预期的输出。但是,我需要澄清一些有关 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) 块。