注册 登录  
 加关注
   显示下一条  |  关闭
温馨提示!由于新浪微博认证机制调整,您的新浪微博帐号绑定已过期,请重新绑定!立即重新绑定新浪微博》  |  关闭

淡泊明智

 
 
 

日志

 
 

ConcurrentLinkedQueue(无界队列) 的outofMemory错误解决方案  

2012-11-28 16:57:24|  分类: Java多线程 |  标签: |举报 |字号 订阅

  下载LOFTER 我的照片书  |

期项目中碰到一个问题。

      一个线程从MQ中取得数据,置于一个队列A(ConcurrentLinkedQueue类型)中,其它线程从A中取出数据进行处理。程序在低速运行时没有问题。在进行压力测试时,200万条数据以4000条/秒的速度进入A后,程序崩溃dump出core文件。

    当时百思不得其解,经某大牛指点,可能是ConcurrentLinkedQueue没有对长度进行限制,在数据高速进入时导致队列A长度暴涨,进而吃光内存,导致程序崩溃。

   后将其改成LinkedBlockingQueue可以解决程序崩溃的问题

  后在国外论坛上查到如下内容

The size of a ConcurrentLinkedQueue is unbounded, so if producers are putting in items faster than consumers can remove them, eventually it will eat up your memory indeed. If you want to limit the size of the queue, try a blocking queue, such as LinkedBlockingQueue or ArrayBlockingQueue instead. The size of the first can be optionally bounded, while the second is always bounded.

  评论这张
 
阅读(877)| 评论(1)
推荐 转载

历史上的今天

评论

<#--最新日志,群博日志--> <#--推荐日志--> <#--引用记录--> <#--博主推荐--> <#--随机阅读--> <#--首页推荐--> <#--历史上的今天--> <#--被推荐日志--> <#--上一篇,下一篇--> <#-- 热度 --> <#-- 网易新闻广告 --> <#--右边模块结构--> <#--评论模块结构--> <#--引用模块结构--> <#--博主发起的投票-->
 
 
 
 
 
 
 
 
 
 
 
 
 
 

页脚

网易公司版权所有 ©1997-2018