二十多年我没有工作是什么歌(没有20)
你好呀,我是喜提七天居家隔离得歪歪。这篇文章要从一个奇怪的注释说起,就是下面这张图:
我们可以不用管具体的代码逻辑,只是单单看这个 for 循环在循环里面,专门有个变量 j,来记录当前循环次数第一次循环以及往后每 1000 次循环之后,进入一个 if 逻辑在这个 if 逻辑之上,标注了一个注释:prevent gc.。
prevent,这个单词如果不认识的同学记一下,考试肯定要考的:
这个注释翻译一下就是:防止 GC 线程进行垃圾回收。具体的实现逻辑是这样的:
核心逻辑其实就是这样一行代码:Thread.sleep(0);这样就能实现 prevent gc 了?
懵逼吗?懵逼就对了,懵逼就说明值得把玩把玩这个代码片段,其实是出自 RocketMQ 的源码:org.apache.rocketmq.store.logfile.DefaultMappedFile#warmMappedFile。
事先需要说明的是,我并没有找到写这个代码的人问他的意图是什么,所以我只有基于自己的理解去推测他的意图如果推测得不对,还请多多指教虽然这是 RocketMQ 的源码,但是基于我的理解,这个小技巧和 RocketMQ 框架没有任何关系,完全可以脱离于框架存在。
我给出的修改意见是这样的:
把 int 修改为 long,然后就可以直接把 for 循环里面的 if 逻辑删除掉了。
这样一看是不是更加懵逼了?不要慌,接下来,我给你抽丝剥个茧另外,在“剥茧”之前,我先说一下结论:提出这个修改方案的理论立足点是 Java 的安全点相关的知识,也就是 safepoint官方最后没有采纳这个修改方案。
官方采没采纳不重要,重要的是我高低得给你“剥个茧”。
探索当我知道这个代码片段是属于 RocketMQ 的时候,我想到的第一个点就是从代码提交记录中寻找答案。看提交者是否在提交代码的时候说明了自己的意图。于是我把代码拉了下来,一看提交记录是这样的:
我就知道这里不会有答案了因为这个类第一次提交的时候就已经包含了这个逻辑,而且对应这次提交的代码也非常多,并没有特别说明对应的功能从提交记录上没有获得什么有用的信息于是我把目光转向了 github 的 issue,拿着关键词 prevent gc 搜索了一番。
除了第一个链接之外,没有找到什么有用的信息:
而第一个链接对应的 issues 是这个:https://github.com/apache/rocketmq/issues/4902这个 issues 其实就是我们在讨论这个问题的过程中提出来的,也就是前面出现的修改方案:
也就是说,我想通过源码或者 github 找到这个问题权威的回答,是找不到了于是我又去了这个神奇的网站,在里面找到了这个 2018 年提出的问题:https://stackoverflow.com/questions/53284031/why-thread-sleep0-can-prevent-gc-in-rocketmq。
问题和我们的问题一模一样,但是这个问题下面就这一个回答:
这个回答并不好,因为我觉得没答到点上,但是没关系,我刚好可以把这个回答作为抓手,把差的这一点拉通对齐一下,给它赋能先看这个回答的第一句话:It does not(它没有)问题就来了:“它”是谁?“没有”什么?。
“它”,指的就是我们前面出现的代码“没有”,是说没有防止 GC 线程进行垃圾回收这个的回答说:通过调用 Thread.sleep(0) 的目的是为了让 GC 线程有机会被操作系统选中,从而进行垃圾清理的工作。
它的副作用是,可能会更频繁地运行 GC,毕竟你每 1000 次迭代就有一次运行 GC 的机会,但是好处是可以防止长时间的垃圾收集换句话说,这个代码是想要“触发”GC,而不是“避免”GC,或者说是“避免”时间很长的 GC。
从这个角度来说,程序里面的注释其实是在撒谎或者没写完整不是 prevent gc,而是对 gc 采取了“打散运行,削峰填谷”的思想,从而 prevent long time gc但是你想想,我们自己编程的时候,正常情况下从来也没冒出过“这个地方应该触发一下 GC”这样想法吧?。
因为我们知道,Java 程序员来说,虚拟机有自己的 GC 机制,我们不需要像写 C 或者 C++ 那样得自己管理内存,只要关注于业务代码即可,并没有特别注意 GC 机制那么本文中最关键的一个问题就来了:。
为什么这里要在代码里面特别注意 GC,想要尝试“触发”GC 呢?
先说答案:safepoint,安全点。关于安全点的描述,我们可以看看《深入理解JVM虚拟机(第三版)》的 3.4.2 小节:
注意书里面的描述:有了安全点的设定,也就决定了用户程序执行时并非在代码指令流的任意位置都能够停顿下来开始垃圾收集,而是强制要求必须执行到达安全点后才能够暂停换言之:没有到安全点,是不能 STW,从而进行 GC 的。
如果在你的认知里面 GC 线程是随时都可以运行的。那么就需要刷新一下认知了。接着,让我们把目光放到书的 5.2.8 小节:由安全点导致长时间停顿。里面有这样一段话:
我把划线的部分单独拿出来,你仔细读一遍:是HotSpot虚拟机为了避免安全点过多带来过重的负担,对循环还有一项优化措施,认为循环次数较少的话,执行时间应该也不会太长,所以使用int类型或范围更小的数据类型作为索引值的循环默认是不会被放置安全点的。
这种循环被称为可数循环(Counted Loop),相对应地,使用long或者范围更大的数据类型作为索引值的循环就被称为不可数循环(Uncounted Loop),将会被放置安全点意思就是在可数循环(Counted Loop)的情况下,HotSpot 虚拟机搞了一个优化,就是等循环结束之后,线程才会进入安全点。
反过来说就是:循环如果没有结束,线程不会进入安全点,GC 线程就得等着当前的线程循环结束,进入安全点,才能开始工作什么是可数循环(Counted Loop)?书里面的这个案例来自于这个链接:https://juejin.cn/post/6844903878765314061。
HBase实战:记一次Safepoint导致长时间STW的踩坑之旅如果你有时间,我建议你把这个案例完整的看一下,我只截取问题解决的部分:
截图中的 while(i < end) 就是一个可数循环,由于执行这个循环的线程需要在循环结束后才进入 Safepoint,所以先进入 Safepoint 的线程需要等待它从而影响到 GC 线程的运行所以,修改方案就是把 int 修改为 long。
原理就是让其变为不可数循环(Uncounted Loop),从而不用等循环结束,在循环期间就能进入 Safepoint。接着我们再把目光拉回到这里:
这个循环也是一个可数循环Thread.sleep(0) 这个代码看起来莫名其妙,但是我是不是可以大胆的猜测一下:故意写这个代码的人,是不是为了在这里放置一个 Safepoint 呢,以达到避免 GC 线程长时间等待,从而加长 stop the world 的时间的目的?。
所以,我接下来只需要找到 sleep 会进入 Safepoint 的证据,就能证明我的猜想你猜怎么着?本来是想去看一下源码,结果啪的一下,在源码的注释里面,直接找到了:https://hg.openjdk.java.net/jdk8u/jdk8u/hotspot/file/tip/src/share/vm/runtime/safepoint.cpp。
注释里面说,在程序进入 Safepoint 的时候, Java 线程可能正处于框起来的五种不同的状态,针对不同的状态有不同的处理方案本来我想一个个的翻译的,但是信息量太大,我消化起来有点费劲儿,所以就不乱说了。
主要聚焦于和本文相关的第二点:Running in native codeWhen returning from the native code, a Java thread must check the safepoint _state to see if we must block.。
第一句话,就是答案,意思就是一个线程在运行 native 方法后,返回到 Java 线程后,必须进行一次 safepoint 的检测同时我在知乎看到了 R 大的这个回答,里面有这样一句,也印证了这个点:。
https://www.zhihu.com/question/29268019/answer/43762165
那么接下来,就是见证奇迹的时刻了:
根据 R 大的说法:正在执行 native 函数的线程看作“已经进入了safepoint”,或者把这种情况叫做“在safe-region里”sleep 方法就是一个 native 方法,你说巧不巧?所以,到这里我们可以确定的是:调用 sleep 方法的线程会进入 Safepoint。
另外,我还找到了一个 2013 年的 R 大关于类似问题讨论的帖子:https://hllvm-group.iteye.com/group/topic/38232?page=2
这里就直接点名道姓的指出了:Thread.sleep(0).这让我想起以前有个面试题问:Thread.sleep(0) 有什么用当时我就想:这题真难(S)啊(B)现在发现原来是我道行不够,小丑竟是我自己。
还真的是有用实践前面其实说的都是理论这一部分我们来拿代码实践跑上一把,就拿我之前分享过的《真是绝了!这段被JVM动了手脚的代码!》文章里面的案例publicclassMainTest { public
static AtomicInteger num = new AtomicInteger(0); publicstaticvoidmain(String[] args) throws InterruptedException
{ Runnable runnable=()->{ for (int i = 0; i < 1000000000; i++) { num.getAndAdd(
1); } System.out.println(Thread.currentThread().getName()+"执行结束!"); }; Thread t1 =
new Thread(runnable); Thread t2 = new Thread(runnable); t1.start(); t2.start(); Thread.sleep(
1000); System.out.println("num = " + num); } } 这个代码,你直接粘到你的 idea 里面去就能跑按照代码来看,主线程休眠 1000ms 后就会输出结果,但是实际情况却是主线程一直在等待 t1,t2 执行结束才继续执行。
最新文章
- 惠州网站建设500元全包(做网站怎么收费)有个性的女孩原来都在这里的说说,
- 衡阳网站建设一站式服务(制作公司网站流程)骆驼奶粉什么品牌好,
- 南通企业网站建设制作全包(知识付费网站搭建)品牌国产奶粉排行榜,
- 西宁公司网站建设搭建全包(企业网站搭建商)哪个羊奶粉好,
- 长沙企业网站建设制作全包(网站搭建平台免费)奶类品种,
- 淮南网站建设500元全包(代做网站收费标准)5到12岁喝好奶粉还是牛奶好,
- 福州网站建设一站式服务(网站搭建报价方案)奶粉排行榜排名,
- 衡阳公司网站建设搭建全包(公司做网站哪家好)美国一男子,
- 芜湖网站建设一条龙全包(网站搭建成本高吗)儿童的睡眠障碍,
- 惠州网站建设500元全包(做网站建设公司)儿童青少年护眼指南最新版,
- 上饶企业网站建设制作全包(企业网站搭建步骤)儿童社交能力包括哪些方面,
- 武汉网站建设一条龙全包(外贸网站搭建服务)匹克中国航天事业合作伙伴,
- 莆田网站建设500元全包(哪家做网站公司好)运动怎样保护膝盖关节,
- 南宁网站建设一站式服务(专业公司做网站)一个珠宝店遭到了抢劫 谁在撒谎,
- 无锡网站建设一条龙全包(个人网站搭建平台)珠宝技术培训,
- 台州企业网站建设制作全包(做网站花钱吗知乎)珠宝的消费场景是什么,
- 长春企业网站建设制作全包(做网站谁家做的好)王朝有限公司怎么样,
- 枣庄网站建设一条龙全包(做网站价格)京东京造的东西质量怎么样,
- 西宁网站建设一站式服务(开发网站网络公司)华服衣冠什么意思,
- 连云港网站建设一条龙全包(公司做网站的好处)食品饮料ETF哪只好,
- 大同企业网站建设制作全包(做网站多少钱)中证指数饮料食品c,
- 昆明网站建设500元全包(外贸网站搭建价格)华润和谁联姻,
- 赣州公司网站建设搭建全包(网站搭建服务平台)排名前十的无糖饮料,
- 南宁网站建设一站式服务(影视网站搭建)功能性饮料的优点,
- 长春网站建设500元全包(跨境网站搭建)冬天喝什么口味的奶茶,
- 郑州企业网站建设制作全包(做网站需要什么?)鸡蛋的激素含量高吗?,
- 江门网站建设一站式服务(外贸公司网站搭建)一枚鸡蛋大概重多少千克,
- 保定公司网站建设搭建全包(网站搭建的步骤)2020年中国鸡蛋行业研究报告分析图,
- 鞍山网站建设500元全包(做网站搭建一条龙)鸡蛋价格高低有什么不一样么,
- 芜湖企业网站建设制作全包(企业做网站费用)鸡蛋几块钱,
- 泸州网站建设一条龙全包(解析网站搭建源码)10块钱鸡蛋大概多少个,
- 岳阳网站建设500元全包(电商网站搭建)吃豆腐是什么意思,要怎样做,
- 泰安网站建设一条龙全包(工厂外贸网站搭建)包浆豆腐的功效与作用,
- 慈溪网站建设一站式服务(如何做网站推广)做豆腐原料,
- 砸了9位数冠名费,这款"牛奶爱马仕"却为何跌落“神坛”?
- 银川网站建设一条龙全包(公司官方网站搭建)4人闯关游戏单机游戏,
- 长春企业网站建设制作全包(公司官网网站搭建)健康早餐有什么,
- 岳阳网站建设一站式服务(哪家做网站公司好)早餐牛奶包子好吗,
- 牛奶为啥是“营养冠军”?高钙高蛋白还易吸收,5类人喝了更受益
- 邯郸企业网站建设制作全包(做网站多少钱一年)喝牛奶不可以吃什么?,