转载自  面试官让我讲下线程的TIMED_WAITING状态,我又笑了

面试官Q:你讲下线程状态中的WAITING状态,什么时候会处于这个状态?什么时候离开这个状态?

小菜J 会心一笑,可以撮这里 -> 线程的WAITING状态

面试官Q:那你继续讲下TIMED_WAITING状态

小菜J,又笑了。

一个正在限时等待另一个线程执行一个动作的线程处于这一状态。

A thread that is waiting for another thread to perform an action for up to a specified waiting time is in this state.

更详细的定义还是看 javadoc:

带指定的等待时间的等待线程所处的状态。一个线程处于这一状态是因为用一个指定的正的等待时间(为参数)调用了以下方法中的其一:

  • Thread.sleep

  • 带时限(timeout)的 Object.wait

  • 带时限(timeout)的 Thread.join

  • LockSupport.parkNanos

  • LockSupport.parkUntil

对应的英文原文如下:

Thread state for a waiting thread with a specified waiting time. A thread is in the timed waiting state due to calling one of the following methods with a specified positive waiting time:

  • Thread.sleep

  • Object.wait with timeout

  • Thread.join with timeout

  • LockSupport.parkNanos

  • LockSupport.parkUntil

不难看出,TIMED_WAITING 与 WAITING 间的联系还是很紧密的,主要差异在时限(timeout)参数上。

另外则是 sleep 这一点上的不同。

timed_waiting 的场景

实际上,在上一篇章中谈到的没有参数的 wait() 等价于 wait(0),而 wait(0) 它不是等0毫秒,恰恰相反,它的意思是永久的等下去,到天荒地老,除非收到通知。

具体可见 java 的源代码及相应 javadoc,注意:同时又还存在一种特殊的情况,所谓的“spurious wakeup”(虚假唤醒),我们在下面再讨论。

即是把自己再次活动的命运完全交给了别人(通知者),那么这样会存在什么问题呢?

在这里,我们还是继续上一篇章中的谈到的车厢场景,如不清楚的参见 Java 线程状态之 WAITING。

设想一种情况,乘务员线程增加了厕纸,正当它准备执行 notify 时,这个线程因某种原因被杀死了(持有的锁也随之释放)。这种情况下,条件已经满足了,但等待的线程却没有收到通知,还在傻乎乎地等待。

简而言之,就是存在通知失效的情况。这时,如果有个心机婊线程,她考虑得比较周全,她不是调用 wait(),而是调用 wait(1000),如果把进入 wait set 比喻成在里面睡觉等待。那么 wait(1000)相当于自带设有倒计时 1000 毫秒的闹钟,换言之,她在同时等待两个通知,并取决于哪个先到:

  • 如果在1000毫秒内,她就收到了乘务员线程的通知从而唤醒,闹钟也随之失效;

  • 反之,超过1000毫秒,还没收到通知,则闹钟响起,此时她则被闹钟唤醒。

这种情况类似于双保险。下面是一个动态的 gif 示意图(空的电池代表条件不满足,粉色的乘务员线程负责增加纸张,带有闹钟的乘客线程代表限时等待):

这样,在通知失效的情况下,她还是有机会自我唤醒的,进而完成尿尿动作。

可见,一个线程,她带不带表(闹钟),差别还是有的。其它死心眼的线程则等呀等,等到下面都湿了却依旧可能等不来通知。用本山大叔的话来说:那憋得是相当难受。

以下代码模拟了上述情形,这次,没有让乘务员线程执行通知动作,但限时等待的线程2还是自我唤醒了:

@Testpublic void testTimedWaitingState() throws Exception {class Toilet { // 厕所类int paperCount = 0; // 纸张public void pee() { // 尿尿方法try {Thread.sleep(21000);// 研究表明,动物无论大小尿尿时间都在21秒左右} catch (InterruptedException e) {Thread.currentThread().interrupt();}}}Toilet toilet = new Toilet();// 一直等待的线程1Thread passenger1 = new Thread(new Runnable() {public void run() {synchronized (toilet) {while (toilet.paperCount < 1) {try {toilet.wait(); // 条件不满足,等待} catch (InterruptedException e) {Thread.currentThread().interrupt();}}toilet.paperCount--; // 使用一张纸toilet.pee();}}});// 只等待1000毫秒的线程2Thread passenger2 = new Thread(new Runnable() {public void run() {synchronized (toilet) {while (toilet.paperCount < 1) {try {toilet.wait(1000); // 条件不满足,但只等待1000毫秒} catch (InterruptedException e) {Thread.currentThread().interrupt();}}toilet.paperCount--; // 使用一张纸toilet.pee();}}});// 乘务员线程Thread steward = new Thread(new Runnable() {public void run() {synchronized (toilet) {toilet.paperCount += 10;// 增加十张纸// 粗心的乘务员线程,没有通知到,(这里简单把代码注释掉来模拟)// toilet.notifyAll();// 通知所有在此对象上等待的线程}}});passenger1.start();passenger2.start();// 确保已经执行了 run 方法Thread.sleep(100);// 没有纸,两线程均进入等待状态,其中,线程2进入 TIMED_WAITINGassertThat(passenger1.getState()).isEqualTo(Thread.State.WAITING);assertThat(passenger2.getState()).isEqualTo(Thread.State.TIMED_WAITING);// 此时的纸张数应为0assertThat(toilet.paperCount).isEqualTo(0);// 乘务员线程启动steward.start();// 确保已经增加纸张Thread.sleep(100);// 此时的纸张数应为10assertThat(toilet.paperCount).isEqualTo(10);// 确保线程2已经自我唤醒Thread.sleep(1000);// 如果纸张已经被消耗一张,说明线程2已经成功自我唤醒assertThat(toilet.paperCount).isEqualTo(9);}

虚假唤醒(spurious wakeup)

虽然,前面说到没有参数的 wait() 等价于 wait(0),意思是永久的等下去直到被通知到。但事实上存在所谓的 “spurious wakeup”,也即是“虚假唤醒”的情况,具体可见 Object.wait(long timeout) 中的 javadoc 说明:

A thread can also wake up without being notified, interrupted, or timing out, a so-called spurious wakeup. While this will rarely occur in practice, applications must guard against it by testing for the condition that should have caused the thread to be awakened, and continuing to wait if the condition is not satisfied.

一个线程也能在没有被通知、中断或超时的情况下唤醒,也即所谓的“虚假唤醒”,虽然这点在实践中很少发生,应用应该检测导致线程唤醒的条件,并在条件不满足的情况下继续等待,以此来防止这一点。

换言之,wait 应该总是在循环中调用(waits should always occur in loops),javadoc 中给出了样板代码:

synchronized(obj){while(<condition doesnothold>) {obj.wait(timeout);...// Perform action appropriate to condition}}

简单讲,要避免使用 if 的方式来判断条件,否则一旦线程恢复,就继续往下执行,不会再次检测条件。由于可能存在的“虚假唤醒”,并不意味着条件是满足的,这点甚至对简单的“二人转”的两个线程的 wait/notify 情况也需要注意。

另外,如果对于更多线程的情况,比如“生产者和消费者”问题,一个生产者,两个消费者,更加不能简单用 if 判断。因为可能用的是 notifyAll,两个消费者同时起来,其中一个先抢到了锁,进行了消费,等另一个也抢到锁时,可能条件又不满足了,所以还是要继续判断,不能简单认为被唤醒了就是条件满足了。

关于此话题的更多信息,可参考:

  • Doug Lea 的 《Concurrent Programming in Java (Second Edition)》3.2.3 节。

  • Joshua Bloch 的 《Effective Java Programming Language Guide》,“Prefer concurrency utilities to  wait and  notify”章节。

sleep 时的线程状态

进入 TIMED_WAITING 状态的另一种常见情形是调用的 sleep 方法,单独的线程也可以调用,不一定非要有协作关系,当然,依旧可以将它视作为一种特殊的 wait/notify 情形。

这种情况下就是完全靠“自带闹钟”来通知了。

另:sleep(0) 跟 wait(0) 是不一样的,sleep 不存在无限等待的情况,sleep(0) 相当于几乎不等待。

需要注意,sleep 方法没有任何同步语义。通常,我们会说,sleep 方法不会释放锁。

javadoc中的确切说法是:The thread does not lose ownership of any monitors.(线程不会失去任何 monitor 的所有权)

而较为夸张的说法则是说 sleep 时会抱住锁不放,这种说法不能说说错了,但不是很恰当。

打个不太确切的比方,就好比你指着一个大老爷们说:“他下个月不会来大姨妈”,那么,我们能说你说错了吗?但是,显得很怪异。

就锁这个问题而言,确切的讲法是 sleep 是跟锁无关的。

JLS 中的说法是“It is important to note that neither  Thread.sleep nor  Thread.yield have any

synchronization semantics”。(sleep 和 yield 均无任何同步语义),另一个影响是,在它们调用的前后都无需关心寄存器缓存与内存数据的一致性(no flush or reload)

见《The Java Language Specification Java SE 7 Edition》17.3 Sleep and Yield

所以,如果线程调用 sleep 时是带了锁,sleep 期间则锁还为线程锁拥有。

比如在同步块中调用 sleep(需要特别注意,或许你需要的是 wait 的方法!)

反之,如果线程调用 sleep 时没有带锁(这也是可以的,这点与 wait 不同,不是非得要在同步块中调用),那么自然也不会在sleep 期间“抱住锁不放”。

压根就没有锁,你让它抱啥呢?而 sleep 君则完全是一脸懵逼:“锁?啥是锁?我没听过这玩意!”

带 timeout 的 join 的情景与 wait(timeout) 原理类似,这里不再展开叙述。

LockSupport.parkNanos 和 parkUnitl 也交由读者自行分析。

总结

最后,跟传统进(线)程状态划分的一个最终对比:

面试官让我讲下线程的TIMED_WAITING状态,我又笑了相关推荐

  1. 面试官让我讲下线程的WAITING状态,我笑了

    转载自  面试官让我讲下线程的WAITING状态,我笑了 面试官Q:你讲下线程状态中的WAITING状态,什么时候会处于这个状态?什么时候离开这个状态? 小菜J 会心一笑... 一个正在无限期等待另一 ...

  2. 面试官问:为什么 Java 线程没有 Running 状态?我懵了

    转载自 面试官问:为什么 Java 线程没有 Running 状态?我懵了 什么是 RUNNABLE? 与传统的ready状态的区别 与传统的running状态的区别 当I/O阻塞时 如何看待RUNN ...

  3. 面试官问:为什么 Java 线程没有Running状态?我懵了

    点击上方"朱小厮的博客",选择"设为星标" 后台回复"书",获取 后台回复"k8s",可领取k8s资料 title: 面 ...

  4. java 线程状态_面试官问:为什么Java线程没有Running状态?我懵了

    点击上方"占小狼的博客",选择"设为星标" 本文阅读时间大约4分钟. 来源:https://dwz.cn/dLRLBZab Java虚拟机层面所暴露给我们的状态 ...

  5. 太逗了,面试官让我讲线程 WAITING 状态!

    面试官Q:你讲下线程状态中的WAITING状态,什么时候会处于这个状态?什么时候离开这个状态? 小菜J 会心一笑... 一个正在无限期等待另一个线程执行一个特别的动作的线程处于WAITING状态. & ...

  6. 面试官: 谈谈什么是守护线程以及作用 ?

    来自:小哈学Java 目录 一.什么是守护线程 二.守护线程的作用及应用场景 三.总结 一.什么是守护线程 守护线程相对于正常线程来说,是比较特殊的一类线程,那么它特殊在哪里呢?别急,在了解它之前,我 ...

  7. java线程池原理简答_面试官让我讲讲Java线程池的实现原理,我笑了...

    期待与你,一起进步 随着cpu核数越来越多,不可避免的利用多线程技术以充分利用其计算能力.所以,多线程技术是服务端开发人员必须掌握的技术. 线程的创建和销毁,都涉及到系统调用,比较消耗系统资源,所以就 ...

  8. 面试官系统精讲Java源码及大厂真题 - 23 队列在源码方面的面试题

    23 队列在源码方面的面试题 人要有毅力,否则将一事无成. 引导语 队列在源码方面的面试题,一般面试官会从锁,线程池等知识点作为问题入口,慢慢的问到队列,由于锁.线程池咱们还没有学习到,所以本章就直奔 ...

  9. 面试官系统精讲Java源码及大厂真题 - 28 Future、ExecutorService 源码解析

    28 Future.ExecutorService 源码解析 今天应做的事没有做,明天再早也是耽误了. 引导语 本章和大家一起看下有返回值的线程如何创建,两种线程 API 之间如何关联,介绍一下和线程 ...

最新文章

  1. 深入Java虚拟机读书笔记[10:20]
  2. 是我太天真之被BUG按在地上疯狂摩擦
  3. 笑笑:农民与大款谈差距
  4. in 和 exist 区别
  5. 心路历程(五)-find work and find house
  6. np读取csv文件_pandas.read_csv函数参数详解
  7. 8皇后问题--回溯法 (循环递归)
  8. idea报错 IDEA:clear read-only status
  9. Elastic Stack之Elasticsearch 5.6.12 集群部署实战
  10. Atitit 图像处理 调用opencv 通过java  api   attilax总结
  11. Java反序列化和JNDI注入
  12. 蚂蚁金服高要求的领域建模能力,对研发来说到底指什么?
  13. CTabSheet类源码
  14. 云原生API网关 - 开源项目Hango网关设计与实践
  15. 【java】微信支付生成签名的过程
  16. python公开课乐博学院_Python 变量
  17. Pytorch快速搭建Alexnet实现手写英文字母识别+PyQt实现鼠标绘图
  18. 二本院校学弟大二开始实习,大三收割阿里、腾讯实习offer
  19. RMAN完全恢复与不完全恢复测试
  20. C++与C#的基本类型对照

热门文章

  1. setnx和expire合成一条指令_Python 为什么只需一条语句“a,b=b,a”,就能直接交换两个变量?...
  2. 算法题目——Problem A 二进制(北邮机试)
  3. leetcode538. 把二叉搜索树转换为累加树
  4. mysql id 字段类型转换_mysql 数据类型转换
  5. [Nginx]nginx常用的命令
  6. [PAT乙级]1036 跟奥巴马一起编程
  7. [Java网络编程基础]UDP发送和接收数据
  8. C++ 实现布隆过滤器(BloomFilter)
  9. 数据结构---后序和中序遍历的二叉树序列还原二叉树
  10. Visual Studio 2013 error MS8020 Build tools v140 cannot be found 解决系统 不同部分软件 所依赖编译器版本不同的矛盾