java中wait和notify关键字的简介说明
转自:http://www.java265.com/JavaCourse/202204/2928.html
下文笔者将讲述wait和notify关键字的简介说明,如下所示:
wait()和notify()简介
void notify() 唤醒在此对象监视器上等待的单个线程 void notifyAll() 唤醒在此对象监视器上等待的所有线程 void wait( ) 导致当前的线程等待,直到其他线程调用此对象的notify( ) 方法或 notifyAll( ) 方法 void wait(long timeout) 导致当前的线程等待,直到其他线程调用此对象的notify() 方法或 notifyAll() 方法,或者指定的时间过完。 void wait(long timeout, int nanos) 导致当前的线程等待,直到其他线程调用此对象的notify( ) 方法或 notifyAll( ) 方法, 或其他线程打断了当前线程,或指定的时间过完。
wait(),notify(),notifyAll()都不属于Thread类 而是属于Object基础类 每个对象都有wait(),notify(),notifyAll()的功能 因为每个对象都有锁,锁是每个对象的基础,当然操作锁的方法也是最基础了。 当需要调用以上的方法的时候,一定要对竞争资源进行加锁 如果不加锁的话,则会报 IllegalMonitorStateException 异常 当想要调用wait()进行线程等待时,必须要取得这个锁对象的控制权(对象监视器) 一般是放到synchronized(obj)代码中 在while循环里而不是if语句下使用wait 这样,会在线程暂停恢复后都检查wait的条件, 并在条件实际上并未改变的情况下处理唤醒通知 调用obj.wait( )释放了obj的锁 否则其他线程也无法获得obj的锁,也就无法在synchronized(obj){ obj.notify() } 代码段内唤醒A notify()方法只会通知等待队列中的第一个相关线程(不会通知优先级比较高的线程) notifyAll()通知所有等待该竞争资源的线程(也不会按照线程的优先级来执行) 假设有三个线程执行了obj.wait() 那么obj.notifyAll( )则能全部唤醒tread1,thread2,thread3 但是要继续执行obj.wait()的下一条语句 必须获得obj锁 因此tread1,thread2,thread3只有一个有机会获得锁继续执行 如tread1,其余的需要等待thread1释放obj锁之后才能继续执行 当调用obj.notify/notifyAll后,调用线程依旧持有obj锁 因此,thread1,thread2,thread3虽被唤醒 但是仍无法获得obj锁。 直到调用线程退出synchronized块,释放obj锁后 thread1,thread2,thread3中的一个才有机会获得锁继续执行。
public class WaitNotifyTest { //java265.com示例分享在多线程间共享的对象上使用wait private String[] shareObj = { "true" }; public static void main(String[] args) { WaitNotifyTest test = new WaitNotifyTest(); ThreadWait threadWait1 = test.new ThreadWait("wait thread1"); threadWait1.setPriority(2); ThreadWait threadWait2 = test.new ThreadWait("wait thread2"); threadWait2.setPriority(3); ThreadWait threadWait3 = test.new ThreadWait("wait thread3"); threadWait3.setPriority(4); ThreadNotify threadNotify = test.new ThreadNotify("notify thread"); threadNotify.start(); threadWait1.start(); threadWait2.start(); threadWait3.start(); } class ThreadWait extends Thread { public ThreadWait(String name){ super(name); } public void run() { synchronized (shareObj) { while ("true".equals(shareObj[0])) { System.out.println("线程"+ this.getName() + "开始等待"); long startTime = System.currentTimeMillis(); try { shareObj.wait(); } catch (InterruptedException e) { e.printStackTrace(); } long endTime = System.currentTimeMillis(); System.out.println("线程" + this.getName() + "等待时间为:" + (endTime - startTime)); } } System.out.println("线程" + getName() + "等待结束"); } } class ThreadNotify extends Thread { public ThreadNotify(String name){ super(name); } public void run() { try { //让程序暂停一下 sleep(2000); } catch (InterruptedException e) { e.printStackTrace(); } synchronized (shareObj) { System.out.println("线程" + this.getName() + "开始准备通知"); shareObj[0] = "false"; shareObj.notifyAll(); System.out.println("线程" + this.getName() + "通知结束"); } System.out.println("线程" + this.getName() + "运行结束"); } } }