正确理解wait 和 notify

2024-06-02 23:48
文章标签 正确理解 wait notify

本文主要是介绍正确理解wait 和 notify,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

/***  线程A: 循环50次后等待并放弃锁,让线程B执行。*/
class ThreadA extends Thread{//线程同步的公共数据区	Object oa=null;ThreadA(Object o){this.oa=o;}//线程A执行逻辑public void run(){//线程同步区域,需要申请公共数据的锁synchronized(oa){System.out.println("ThreadA is running......");for(int i=0;i<100;i++){System.out.println("   ThreadA value is "+i);if(i==50){try {//当前线程等待Thread.currentThread().wait();} catch (InterruptedException e) {e.printStackTrace();}}//if(i==50)}//for(int i)}}
}
/***  线程B:等待线程A放弃锁,然后获得锁并执行,完成后唤醒线程A*/
class ThreadB extends Thread{//线程同步的公共数据区	Object ob=null;ThreadB(Object o){this.ob=o;}//线程B执行逻辑public void run(){//线程同步区域,需要申请公共数据的锁synchronized(ob){System.out.println("ThreadB is running......");for(int i=0;i<50;i++){System.out.println("   ThreadB value is "+i);}//唤醒等待的线程notify();}}
}
//测试
public class ThreadTest {  public static void main(String[] args){Object lock=new Object(); //公共数据区ThreadA threada=new ThreadA(lock);ThreadB threadb=new ThreadB(lock);threada.start(); //线程A执行threadb.start(); //线程B执行}
}  

程序很简单,就是让线程A,B交替打印。但是运行的时候会抛出两个异常:

Exception in thread "Thread-0" java.lang.IllegalMonitorStateException: current thread not owner

Exception in thread "Thread-1" java.lang.IllegalMonitorStateException: current thread not owner

 

     问题就处在ThreadA中的Thread.currentThread().wait(); ThreadB中的notify();上。

 

     初学者理解wait()的时候都认为是将当前线程阻塞,所以Thread.currentThread().wairt();视乎很有道理。但是不知道大家有没有发现,在JDK类库中wait()notify()方法并不是Thread类的,而是Object()中的。我们仔细看看wait方法的JDK文档:

 

    public final void wait() throws InterruptedException

 

    在其他线程调用此对象的 notify() 方法或 notifyAll() 方法前,当前线程等待。 换句话说,此方法的行为就好像它仅执行 wait(0) 调用一样。

    当前线程必须拥有此 对象监视器 。该线程发布对此监视器的所有权并等待 ,直到其他线程通过调用 notify 方法,或 notifyAll 方法通知在此对象的监视器上等待的线程醒来。 然后该线程将等到重新获得对监视器的所有权后才能继续执行。  

    对于某一个参数的版本,实现中断和虚假唤醒是可能的,而且此方法应始终在循环中使用:

                                    synchronized (obj) {

                                           while (<condition does not hold>)

                                                 obj.wait(); 

                                           // Perform action appropriate to condition

                                     }

     此方法只应由作为此对象监视器的所有者的线程来调用。

     抛出:  IllegalMonitorStateException - 如果当前线程不是此对象监视器的所有者。

               InterruptedException - 如果在当前线程等待通知之前或者正在等待通知时,任何线程中断了当前线程。在抛出此异常时,当前线程的中断状态 被清除。

 

 

    看完JDK文档以后,很显然,只要把开始的程序中Thread.currentThread().wait();改成oa.wait() 。 notify();改成 ob.notify()就没有问题了。

 

     也就是说,只能通过同步块obj来调用wait/notify方法 ,而不能通过想当然的线程调用这两个方法。至于为什么是这样,我有一种想法,大家可以一起讨论一下:

 

      首先,我们都知道JVM会给每一个对象都分配唯一的一把锁。这把锁是在对象中的。

      然后,当Thread-0线程获得了这把锁后,应该是在对象中的锁内记录下当前占有自己的线程号,并把自己设置为已被占用。那么当Thread-0需要放弃锁的时候,锁对象会把 Thread-0放入到锁的等待队列中 。而这一切和Thread-0是没有任何关系的。自然也轮不到Thread-0对象来调用某个方法来改变另一个对象中的锁(这一点也说不通,我自己的锁凭什么让你来改)。

      因此,也就出现用改变公共数据区对象的锁的方法是通过共数据区对象本省来调用,和线程对象是没有关系的。

 

      事实上,每一个同步锁lock下面都挂了几个线程队列,包括就绪(Ready)队列,等待(Waiting)队列等。当线程A因为得不到同步锁lock,从而进入的是lock.ReadyQueue(就绪队列),一旦同步锁不被占用,JVM将自动运行就绪队列中的线程而不需要任何notify()的操作。但是当线程Await()了,那么将进入lock.WaitingQuene(等待队列),同时如果占据的同步锁也会放弃。而此时如果同步锁不唤醒等待队列中的进程(lock.notify()),这些进程将永远不会得到运行的机会。

 

      就绪队列和等待队列有很大的不同,这一点要牢记。

 

      对于objectwaitnotifynotifyAll的理解,可以参见《Java 虚拟机体系结构 》中堆内存区的内容,就会有更加深刻的理解了。

这篇关于正确理解wait 和 notify的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1025437

相关文章

linux 下Time_wait过多问题解决

转自:http://blog.csdn.net/jaylong35/article/details/6605077 问题起因: 自己开发了一个服务器和客户端,通过短连接的方式来进行通讯,由于过于频繁的创建连接,导致系统连接数量被占用,不能及时释放。看了一下18888,当时吓到了。 现象: 1、外部机器不能正常连接SSH 2、内向外不能够正常的ping通过,域名也不能正常解析。

一次生产环境大量CLOSE_WAIT导致服务无法访问的定位过程

1.症状 生产环境的一个服务突然无法访问,服务的交互过程如下所示: 所有的请求都是通过网关进入,之后分发到后端服务。 现在的情况是用户服务无法访问商旅服务,网关有大量java.net.SocketTimeoutException: Read timed out报错日志,商旅服务也不断有日志打印,大多是回调和定时任务日志,所以故障点在网关和商旅服务,大概率是商旅服务无法访问导致网关超时。 后

selenium的webdriver三种等待方式(显式等待WebDriverWait+implicitly_wait隐式等待+sleep强制等待)

隐式等待是等页面加载,不是等元素!!! 1、显式等待  一个显式等待是你定义的一段代码,用于等待某个条件发生然后再继续执行后续代码。显式等待是等元素加载!!! from selenium import webdriverfrom selenium.webdriver.common.by import Byfrom selenium.webdriver.support.ui import

java join sleep wait notify notifyAll

sleep:在指定的毫秒数内让当前正在执行的线程休眠(暂停执行),此操作受到系统计时器和调度程序精度和准确性的影响。该线程不丢失任何监视器的所属权。  通过调用sleep使任务进入休眠状态,在这种情况下,任务在指定的时间内不会运行。 调用sleep的时候锁并没有被释放。 休眠  Java SE5引入了更加显示的sleep()版本作为TimeUnit类的一部分,这个方法允许你

java线程 yield,sleep,join,synchronized wait notify notifyAll,ReentrantLock lock condition, 生产者消费者

yield,sleep,join yield,join,sleep,join是Thread中的方法,不需要 在synchronized 代码块中调用,和synchronized 没关系,也不会释放锁。 Thread.sleep(100);Thread.yield();Thread t;t.join(); (1)yield()不一定保证让出cpu yield()只是使当前线程重新回

65-java中sleep方法和wait方法的区别

‌Java中的sleep()方法和wait()方法的主要区别在于它们的所属类、使用方式、唤醒机制、锁的处理、异常处理以及用途。‌   ‌所属类不同‌:sleep()方法是Thread类的静态方法,可以在任何线程中使用。而wait()方法是Object类的一个实例方法,只能在同步代码块或同步方法中使用。‌12   ‌使用方式不同‌:sleep()方法用于使线程暂停执行指定的时间,不需要任何条件即可

Java Lock 中使用 await() 和 signal()实现 wait()/notify()机制

** Java Lock 中使用 await() 和 signal()实现 wait()/notify()机制 ** 案例 import java.util.concurrent.locks.Condition;import java.util.concurrent.locks.Lock;import java.util.concurrent.locks.ReentrantLock;

App使用Job中遇到的WAIT DEV_NOT_DOZING的解决方案

摘要: 由于原生Job机制会使用Doze的白名单,故遇到WAIT:DEV_NOT_DOZING现象,一般配置为Whitelist user apps名单即可解决问题 Doze名单类型 配置对象 配置方法 影响 Whitelist user apps 第三方应用 1.Adb shell 命令:adb shell dumpsys deviceidle whitelist +com.t

synchronized wait()/notify 对比 ReentrantLock await()/signal()

结论 synchronized synchronized 配合 wait()/notify 无法实现精准唤醒线程 ReentrantLock ReentrantLock 配合 Condition await()/signal() 可以实现精准唤醒线程 (指唤醒指定的线程) ReentrantLock 如何实现精准唤醒线程 一个 lock 配合多个 Condition, 且