Wait-Notify机制可以说是实现阻塞操作较为高效的一种方式。虽然在实际中鼓励使用类库中已有的满足条件的类,或基于类库中的类来做满足自己特殊需求的开发,并不建议直接使用如此底层的机制,但了解其原理还是很有必要的。
典型的Wait-Notify场景一般与以下内容相关:
1、状态变量(State Variable)
当线程需要wait的时候,总是因为一些状态不满足导致的。如往BlockingQueue里加元素队列已满的时候。当状态满足的时候,程序就可以执行下去。
2、条件断言(Condition Predicate)
当线程确定是否进入wait或者从notify中醒来的时候是否继续往下执行,大都要测试状态条件是否满足,如往BlockingQueue里加元素队列已满,于是阻塞,后续其它线程从队列里取走了元素,就通知在等待的线程“队列不是满的了,可以往里加东西了”,这时候在等待的线程就会醒来,然后看看是不是真的队列不为满的状态,如果是,就将元素添加进去,如果不是,就继续等待。
3、条件队列(Condition Queue)
每个对象都有一个内置的条件队列,当一个线程在该对象是调用wait的时候,就会将该线程加入该对象的条件队列。
基于以上,接下来说说wait(以及其它两个带超时时间的wait重载版本,后文如无特别说明,wait就表示这三种操作)、notify(以及notifyAll,后文若无特别说明,notify表示这两种操作)操作。
在调用wait、notify的时候,必须先持有锁,且状态变量须由该锁保护,而内置锁对象与内置条件队列对象又是同一个对象。也就是说,要在某个对象上执行wait,notify,先必须锁定该对象,而对应的状态变量也是由该对象锁保护的。如果在调用wait、notify的时候没有持有锁,将会抛出以下错误:
Exception in thread “main” java.lang.IllegalMonitorStateException
这很容易通过下面的代码重现:
package com.ticmy.concurrency; public class TestWatiNotifyMechanism { private static Object obj = new Object(); public static void main(String[] args) throws Exception { //错误代码,无意义,仅测试用 obj.wait(); //obj.notify(); } }
如果上述代码在obj上调用wait,而持有其他对象的锁呢?
package com.ticmy.concurrency; public class TestWatiNotifyMechanism { private static Object obj = new Object(); public static void main(String[] args) throws Exception { //错误代码,无意义,仅测试用 synchronized(TestWatiNotifyMechanism.class) { obj.wait(); //obj.notify(); } } }
情况和没有锁一样。只有在哪个对象上调用wait、notify,就锁定哪个对象才可以。上面的代码,只要锁定obj对象就可以了:
package com.ticmy.concurrency; public class TestWatiNotifyMechanism { private static Object obj = new Object(); public static void main(String[] args) throws Exception { //无意义,仅测试用,勿模仿 synchronized(obj) { obj.wait(); // obj.notify(); } } }
当在obj对象上调用wait操作的时候,就会释放当前持有的锁,并将线程加入到obj所属的条件队列,而后阻塞,直到有其它线程在该obj上调用了notify操作或阻塞线程被中断或wait超时。
当调用Object#notify()方法时,会去唤醒对应对象条件队列中的某个线程,至于唤醒的是哪个线程,这是不确定的,选择是任意性的。当调用Object#notifyAll()方法时,会唤醒条件队列中的所有线程。当唤醒一个线程或所有线程时,这个或这些线程需要自动重新获得原先wait时释放的锁,它(们)并不一定立马就能执行,像其它线程一样,需要等待CPU来调度,需要与其它线程竞争执行前需要获得的锁。
线程的wait操作的典型代码结构如下:
void op() throws InterruptedException { synchronized(obj) { while(条件不满足) { obj.wait(); } } }
为什么要在循环中wait?有以下几个原因。
1、一个对象锁可能用于保护多个状态变量,当它们都需要wait-notify操作时,如果不将wait放到while中就有问题。例如,某对象锁obj保护两种状态变量a和b,当a的条件断言不成立时发生了wait操作,当b的条件断言不成立时也发生了wait操作,两个线程被加入到obj对应的条件队列中,现在若改变状态变量a的某操作发生,在obj上调用了notifyAll操作,obj对应的条件队列里的所有线程均被唤醒,之前等待a的某个或几个线程去判断a的条件断言可能成立了,但b对应的条件断言肯定仍不成立,而此时等待b的线程也被唤醒了,所以需要循环判断b的条件断言是否满足,如果不满足,继续wait。
2、多个线程wait的同一个状态的条件断言。如BlockingQueue场景下,当前队列是空的,多个线程要从里面取元素,于是都wait了。此时另一个线程往里面添加了一个元素,调用了notifyAll操作,唤醒了所有线程,但只有一个线程能拿到那个新加进来的元素,继续走下去,其它的仍需等待。
3、虚假唤醒。在没有被通知、中断或超时的情况下,线程自动苏醒了。虽然这种情况在实践中很少发生,但是必须通过循环检测条件是否满足的方式来防止其发生,如果不满足该条件,则继续等待。
notify操作有两个方法可用,nofity和notifyAll,顾名思义,前者每次唤醒一个线程,后者唤醒所有线程。当唤醒所有线程的时候,会增加上下文切换、锁竞争。但很多时候,使用notify是有风险的,多个线程在同一个条件队列里等待不同的条件断言成立,极可能本该唤醒的线程没唤醒。那么什么时候才能用notify呢?牛人们已经总结好了,需要满足以下两个条件:
1、该对象的条件队列只关联了一个条件断言,且线程被唤醒后执行的代码逻辑是相同的;
2、单进单出。一次notify(这里不是指notify方法)能唤醒的线程至多一个。
对于第一点,在为什么要循环中wait以及为什么notify方法有风险时已经说过了。对于第二点,比如要实现一个类似开/关锁存器(在构造CountDownLatch的时候传入1)的功能,所有线程调用await()操作,最终某一线程调用countDown()操作,该countDown()操作就需要唤醒所有wait的线程。在这种场景下,第二条是不满足的——使用notify方法,其它线程将无法唤醒。
上面说到的都是内置锁,内置条件队列,与之对应的,有显式锁(Lock),显式条件队列(Lock#newCondition())
Lock#newCondition()返回一个Condition对象,该对象上对应于操作条件队列的wait和notify方法为:await、signal。与内置锁一样,要调用Condition的await、signal,需要锁定创建该Condition的Lock。如下代码形式:
package com.ticmy.concurrency; import java.util.concurrent.locks.Condition; import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReentrantLock; public class TestWatiNotifyMechanism { private static Lock lock = new ReentrantLock(); private static Condition condition = lock.newCondition(); public static void main(String[] args) throws Exception { //无意义,仅测试用,勿模仿 lock.lock(); try { condition.await(); } finally { lock.unlock(); } } }
除了这个对应关系不一样,其他诸如需要在循环中await,以及使用signal()还是signalAll()等原理与前面一致,不再赘述。需要说到的是,它与内置锁、内置条件队列的区别。
1、内置锁对象只有一个条件队列,而显式锁可以通过newCondition方法创建多个条件队列,这样就可以避免不同的条件断言关联同一个条件队列造成的问题。
2、如同Lock比内置锁更灵活一样,显式的条件队列也提供了更多的方法供调用(如等待的时候不可被中断的awaitUninterruptibly方法),更多方法参见java.util.concurrent.locks.Condition的JAVA API。
3、Condition也有wait、notify方法,它们从Object类继承而来,一般实际中不会调用这些方法(要调用这些方法必须持有Condition对象的锁,而不是Lock的锁定)以避免混淆。
4、Condition可以继承Lock的公平策略。如new ReentrantLock的时候传入的公平策略参数。当公平策略为true的时候,signal的时候,Condition中的线程唤醒顺序是FIFO的。
至于是选择显式的条件队列还是内置的,如同内置锁和Lock一样,取决于应用是否需要使用内置条件队列无法提供而显式条件队列提供了的特性。如果已使用了Lock,那么使用Condition是自然而然的事情。
相关推荐
主要介绍了详解Java程序并发的Wait-Notify机制,多线程并发是Java编程中的重要部分,需要的朋友可以参考下
在学习Java过程中,自己收集了很多的Java的学习资料,分享给大家,有需要的欢迎下载,希望对大家有用,一起学习,一起进步。
一个简单的线程同步机制,也能实例了解wait notify的使用,notify与notifyAll的区别
在学习Java过程中,自己收集了很多的Java的学习资料,分享给大家,有需要的欢迎下载,希望对大家有用,一起学习,一起进步。
5. Java多线程学习(四)等待/通知(wait/notify)机制 6. Java多线程学习(五)线程间通信知识点补充 7. Java多线程学习(六)Lock锁的使用 8. Java多线程学习(七)并发编程中一些问题 9. Java多线程学习(八...
Java多线程的等待唤醒机制代码演示 通过代码,完整的还原消费者和生产者的等待唤醒过程 生产者和消费者是一个十分经典的多线程协作模式 **常见方法:** - void wait() 当前线程等待,直到被其他线程唤醒 - void...
1.概念 线程一共有6中状态,相互之间可以互相转换。 等待唤醒案例(线程之间的通信) 实现: 等待唤醒案例:线程之间的通信 ... 只有锁对象才能调用wait和notify方法 Obejct类中的方法 void wait
java多线程设计模式 线程的创建和重起 线程的同步 wait/notify/sleep机制 Worker Pattern
python 多线程的同步机制 以python2例程的方式讲解了python 多线程的同步 常用的方法,主要是锁、条件同步、队列 ... 保证每一个wait()方法调用都有一个相对应的notify()调用,当然也可以调用notifyAll()方法以
结合多线程技术的wait和notify机制以及锁的同步控制技术,提出一种组件分类触发调度机制,有效地解决具有复杂系组件之间的调度运行问题,保证微命令的有序执行。与已有的模型机虚拟实验平台相比,该实验平台不仅在...
采用同步机制synchronized/wait(notify)或者lock(unlock)/condition variable实现两个producer和一个consumer之间协调运行。运行结果输出格式为:Put(or Get) number {[content] length start_index end_index} 包含...
Java多线程机制 9.1 Java中的线程 9.2 Thread的子类创建线程 ...9.7 在同步方法中使用wait()、notify 和notifyAll()方法 9.8 挂起、恢复和终止线程 9.9 计时器线程Timer 9.10 线程联合 9.11 守护线程
Wait、notify 实现job类,设置触发器 放到调度器中 start 10.Springboot是怎么整合quartz的? 11.Rides的几种数据类型及应用场景? 12.工作流 activety? 13.禅道的使用 14.Cron表达式多看看 15.父子模型 16.消息...
注意:上述方法只能被同步监听锁对象来调用,这也是为啥wait() 和 notify()方法都在 Object 对象中,因为同步监听锁可以是任意对象,只不过必须是需要同步线程的共同对象即可,否则别的对象调用会报错: java.lang...
41、谈谈wait/notify关键字的理解 42、什么导致线程阻塞?线程如何关闭? 43、如何保证线程安全? 44、如何实现线程同步? 45、线程间操作List 46、谈谈对Synchronized关键字,类锁,方法锁,重入锁的理解 49...
Condition被称为条件变量,除了提供与Lock类似的acquire和release方法外,还提供了wait和notify方法。线程首先acquire一个条件变量,然后判断一些条件。如果条件不满足则wait;如果条件满足,进行一些处理改变条件后...
文章目录1 线程基础、线程之间的共享与协作1.1 cpu时间片轮询机制1.2 进程与线程1.3 并行与并发1.4 启动线程的三种方式1.5 停止线程1.6 线程的生命周期1.7 守护线程1.8 synchronized关键字1.9 volatile关键字1.10 ...
wait和notify 线程池 锁 源码分析concurrent包 ConcurrentHashMap CopyOnWriteArrayList BlockingQeque ThreadLocal 反射 Kotlin Kotlin的优势 协程 Android热门技术 代码插桩技术 动态代理 插件化 热修复 日志系统 ...
线程通讯:线程之间通过 wait,notify 等⽅方式通讯。保证每次上下⽂文切换都是有意义的。减 少⽆无谓的线程切换。 java.nio.中提供了了 Selector:通过调⽤用Selector的select⽅方法可以从所有的Channel中找到...
Java高并发相关知识点包括: 线程:Java多线程的实现方式,包括继承Thread类和实现Runnable接口。 锁:Java中的锁机制,包括...线程间通信:Java中的线程间通信,包括wait()、notify()、notifyAll()等方法。