void notify() Wakes up a single thread that is waiting on this object’s monitor. 译:唤醒在此对象监视器上等待的单个线程 void notifyAll() Wakes up all threads that are waiting on this object’s monitor. 译:唤醒在此对象监视器上等待的所有线程 void wait( ) Causes the current thread to wait until another thread invokes the notify() method or the notifyAll( ) method for this object. 译:导致当前的线程等待,直到其他线程调用此对象的notify( ) 方法或 notifyAll( ) 方法 void wait(long timeout) Causes the current thread to wait until either another thread invokes the notify( ) method or the notifyAll( ) method for this object, or a specified amount of time has elapsed. 译:导致当前的线程等待,直到其他线程调用此对象的notify() 方法或 notifyAll() 方法,或者指定的时间过完。 void wait(long timeout, int nanos) Causes the current thread to wait until another thread invokes the notify( ) method or the notifyAll( ) method for this object, or some other thread interrupts the current thread, or a certain amount of real time has elapsed. 译:导致当前的线程等待,直到其他线程调用此对象的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中的一个才有机会获得锁继续执行。
测试用例:
1 package test; 2 3 /** 4 * @author zsh 5 * @company wlgzs 6 * @create 2019-02-25 9:02 7 * @Describe 多线程方法wait() and notify() 方法测试 8 */ 9 public class WaitNotifyTest { 10 11 // 在多线程间共享的对象上使用wait 12 private String[] shareObj = {"true"}; 13 14 //线程等待 15 class ThreadWait extends Thread{ 16 17 public ThreadWait(String name){ 18 super(name); 19 } 20 21 @Override 22 public void run() { 23 synchronized (shareObj){ 24 while ("true".equals(shareObj[0])){ 25 System.out.println("线程"+this.getName()+"开始等待"); 26 long startTime = System.currentTimeMillis(); 27 try { 28 shareObj.wait(); 29 } catch (InterruptedException e) { 30 e.printStackTrace(); 31 } 32 long endTime = System.currentTimeMillis(); 33 System.out.println("线程"+this.getName()+"等待的时间为"+ 34 (endTime - startTime)); 35 } 36 } 37 System.out.println("线程" + this.getName() + "等待结束"); 38 } 39 } 40 41 //线程唤醒 42 class ThreadNotify extends Thread{ 43 44 public ThreadNotify(String name){ 45 super(name); 46 } 47 48 @Override 49 public void run() { 50 try { 51 // 给等待线程等待时间 52 sleep(3000); 53 } catch (InterruptedException e) { 54 e.printStackTrace(); 55 } 56 synchronized (shareObj){ 57 System.out.println("线程" + this.getName() + "开始准备通知"); 58 shareObj[0] = "false"; 59 shareObj.notifyAll(); 60 System.out.println("线程" + this.getName() + "通知结束"); 61 } 62 System.out.println("线程" + this.getName() + "运行结束"); 63 } 64 } 65 66 public static void main(String[] args) { 67 WaitNotifyTest waitNotifyTest = new WaitNotifyTest(); 68 ThreadWait threadWait1 = waitNotifyTest.new ThreadWait("wait thread1"); 69 /** 70 * 优先级 : 只能反映线程的 重要程度 或者是 紧急程度 , 不能决定 是否一定先执行 71 * setPriority() 72 * 1~10 1最低 10最高 5是默认值 73 */ 74 threadWait1.setPriority(2); 75 ThreadWait threadWait2 = waitNotifyTest.new ThreadWait("wait thread2"); 76 threadWait2.setPriority(3); 77 ThreadWait threadWait3 = waitNotifyTest.new ThreadWait("wait thread3"); 78 threadWait3.setPriority(4); 79 80 ThreadNotify threadNotify = waitNotifyTest.new ThreadNotify("notify thread"); 81 82 threadNotify.start(); 83 threadWait1.start(); 84 threadWait2.start(); 85 threadWait3.start(); 86 } 87 88 89 }