等待方遵循如下原则:
1.获取对象的锁
2.如果条件不满足,那么调用对象的wait()方法,被通知后任要检查条件
3.条件满足则进行对于的逻辑
伪代码如下:
synchronized(对象) { while (条件不满足) { 对象.wait(); } 对应的逻辑; }
通知方遵循如下原则:
1.获得对象的锁
2.改变条件
3.通知所有等待在对象上的线程
对应的伪代码如下:
synchronized(对象) { 改变条件 对象.notifyAll(); }
需要注意
1.使用wait(),notify()和notifyAll()时需要先调用对象加锁
2.使用wait()方法后,线程状态由RUNNING变为WAITING,并将当前线程放置到对象的等待队列
3.notify()或notifyAll()方法调用后,等待线程依旧不会从wait()返回,需要调用notify()或notifyAll()的线程释放锁之后,等待线程才会有机会从wait()返回
4.notify()方法将等待队列中的一个等待线程从等待队列中移动到同步队列,而notifyAll()方法则时将等待队列中所有的线程全部移到同步队列,被移动的线程的状态由WAITING变为BLOCKED;
5.从wait()方法返回的前提是获得了所有调用对象的锁
等待超时模式
假设超时时间段时T,那么可以推断在当前时间 now + T之后就好超时;
定义如下变量:
-
等待持续时间:REMAINING = T
-
超时时间:FUTURE = now + T
这时仅需要wait(REMAINING) 即可,在wait(REMAINING)返回之后将会执行:REMAINING = FUTURE - now;如果REMAINING 小于等于0,表示已经超时,直接退出,否则将继续执行wait(REMAINING);
伪代码如下:
public synchronized Object get(long mills) throw InterruptedException { long future = System.currentTimeMillis() + mills; long remaining = mills; //当超时大于0并且result返回值不满足要求 while ((result == null) && remaining > 0) { wait(remaining); remaining = future - System.currentTimeMillis(); } return result; }