3年java开发竟然还不知道Lambda的这个坑-创新互联

背景

我们提供的服务有:网站建设、做网站、微信公众号开发、网站优化、网站认证、雁峰ssl等。为上1000家企事业单位解决了网站和推广的问题。提供周到的售前咨询和贴心的售后服务,是有科学管理、有技术的雁峰网站制作公司

有朋友反馈zk连接很慢。整理出zk连接的关键逻辑如下:

3年java开发竟然还不知道Lambda的这个坑

上面的代码造成第一次调用ClientZkAgent.getInstance的时候,需耗时10s, 这个时间恰好跟semaphore的超时时间相当. 在此期间,整个世界好像停滞了一样。

分析

在本地重现后,通过jstack获得系统停滞期间的线程栈,发现这个时候zookeeper的EventThread有个比较奇怪的现象:

3年java开发竟然还不知道Lambda的这个坑

客户端实际上很快就连上了zookeeper并返回后生成了SyncConnected事件,而且EventThread已经在回调Watcher.process方法了,但似乎事件线程就一直hold在上面#_1的位置无法往下走, 同时,lambda表达式变成了ClientZkAgent的一个方法了:lambda$connect$0。

了解了一下Java中lambda的实现方式,事情水落石出了。

3年java开发竟然还不知道Lambda的这个坑

简而言之,jvm会把lambda表达式转换成所在类的一个方法lambda${method}${seq}(method为该lambda所在的方法名,例如上面的connect方法),同时通过动态代理生成一个代理类(该代理类实现了lambda表达式所代表的具体接口),在该代理类中调用lambda${method}${seq}。

在上面的例子中,生成的代理类大概如下:

3年java开发竟然还不知道Lambda的这个坑

再梳理一下:

业务线程:

1.通过静态方法ClientZkAgent.getInstance()获取实例,第一次访问的时候会触发类ClientZkAgent的装载。

2.装载过程中,装载静态成员instance,这时候会尝试创建一个ClientZkAgent对象。

3.在ClientZkAgent的构造函数中连接zk,并通过CountdownLatch进入阻塞状态。注意这时候类装载还没完成。

4.CountdownLatch超时后完成对象的初始化以及整个类的加载

zk事件线程:

SyncConnected事件触发后,调用ClientZkAgent.lambda$connect$0(event), 试图唤醒业务线程(唤醒逻辑在lambda中)。

然而这时候ClientZkAgent还没加载完,事件线程只能等待类加载流程的结束。

业务线程加载完ClientZkAgent后,事件线程完成事件的处理。

可见,在这个过程中,两个线程相互等待(类似死锁但不是死锁),直至业务线程超时后才化解这个局面。

欢迎大家关注我的公种浩【程序员追风】,文章都会在里面更新,整理的资料也会放在里面。

解决

修改ClientZkAgent的初始化逻辑如下:

3年java开发竟然还不知道Lambda的这个坑

最后

欢迎大家一起交流,喜欢文章记得点个赞,感谢支持!

另外有需要云服务器可以了解下创新互联scvps.cn,海内外云服务器15元起步,三天无理由+7*72小时售后在线,公司持有idc许可证,提供“云服务器、裸金属服务器、高防服务器、香港服务器、美国服务器、虚拟主机、免备案服务器”等云主机租用服务以及企业上云的综合解决方案,具有“安全稳定、简单易用、服务可用性高、性价比高”等特点与优势,专为企业上云打造定制,能够满足用户丰富、多元化的应用场景需求。


网页名称:3年java开发竟然还不知道Lambda的这个坑-创新互联
文章位置:http://scyanting.com/article/dicssh.html