Java多线程之wait()和notify()

xiaoxiao2021-03-01  32

直接看测试代码吧,细节之处,详见注释

packagecom.jadyer.thread.wait; /** *Java多线程之wait()和notify()的妙用 *@see================================================================================================================= *@see问题:同时启动两个线程和同时启动四个线程,控制台打印结果是不同的 *@see同时启动两个线程时,控制台会很规律的输出1010101010101010 *@see同时启动四个线程时,控制台起初会规律的输出10101010,一旦某一刻输出一个负数,那么后面的输出就会"一错再错" *@see分析:对线程而言,任何一种情况,都是合理的 *@see这里假设其中的一种情况:tt22先执行,此时number=0,所以执行到了decrease()方法中的wait()方法,于是tt22被阻塞 *@see接着tt44执行了,此时number=0,所以也执行到了decrease()方法中的wait()方法,于是tt44也被阻塞了 *@see然后tt11执行了,此时number=0,www.linuxidc.com于是便执行到了increase()方法中的number++和notify()方法 *@see重点在于tt11执行到notify()方法时,我们假设该方法唤醒了tt44线程,于是tt44开始执行decrease()方法中的number-- *@see此时number=-1,然后执行到了decrease()方法中notify()方法,我们同样假设该notify()方法唤醒的是tt22线程 *@see同样的道理,number又被减减了,于是number=-2,并被打印到控制台了,然后再假设tt22中的notify()方法唤醒的是tt11 *@see如此的循环往复,就看到那种"一错再错"的效果了 *@see================================================================================================================= *@see修复:我们应当在wait()被唤醒的时候,再判断一次,然后再决定是否让该线程继续wait()下去 *@see因为,当某个线程被唤醒时,它不知道外界在其睡眠的期间发生了神马,所以要再判断一次。所以把if()改为while()判断,即可 *@see================================================================================================================= *@see补充:如果只有两个线程的话,一个是对number增加的线程,一个是对number减少的线程,此时用if()判断是没有问题的 *@see因为无论线程如何的唤醒,它所唤醒的都是另一个线程,不存在第三个线程插进来捣乱的情况 *@see================================================================================================================= *@author宏宇 *@createFeb22,20123:20:05PM */ publicclassWaitNotifyTest{ publicstaticvoidmain(String[]args){Countcount=newCount(); Threadtt11=newThread(newIncreaseThread(count));Threadtt22=newThread(newDecreaseThread(count)); Threadtt33=newThread(newIncreaseThread(count));Threadtt44=newThread(newDecreaseThread(count)); tt11.start();tt22.start(); tt33.start();tt44.start();}} classIncreaseThreadimplementsRunnable{ privateCountcount; publicIncreaseThread(Countcount){ this.count=count;}@Override publicvoidrun(){ for(inti=0;i<20;i++){ try{Thread.sleep((long)(Math.random()*1000));}catch(InterruptedExceptione){e.printStackTrace();}count.increase();}}} classDecreaseThreadimplementsRunnable{ privateCountcount; publicDecreaseThread(Countcount){ this.count=count;}@Override publicvoidrun(){ for(inti=0;i<20;i++){ try{Thread.sleep((long)(Math.random()*1000));}catch(InterruptedExceptione){e.printStackTrace();}count.decrease();}}} classCount{ privateintnumber; publicsynchronizedvoidincrease(){ if(0!=number){ try{//在同步方法(或者同步语句块)中,被锁定的对象可以调用wait()方法,这将导致当前线程被阻塞并释放该对象的互斥锁//即解除了wait()方法所对应的当前对象的锁定状态,然后,其它的线程就有机会访问该对象了wait();}catch(InterruptedExceptione){e.printStackTrace();}}number++;System.out.println(number);//唤醒其它的由于调用了wait()方法而在等待同一个对象的线程//该方法每次运行时,只能唤醒等待队列中的一个线程,至于是哪一个线程被唤醒,则由线程调度器来决定,程序员无法控制notify();} publicsynchronizedvoiddecrease(){ if(0==number){ try{wait();}catch(InterruptedExceptione){e.printStackTrace();}}number--;System.out.println(number);notify();}}
转载请注明原文地址: https://www.6miu.com/read-3649984.html

最新回复(0)