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

淡泊明智

 
 
 

日志

 
 

使用ConcurrentLinkedQueue尽量不用size()  

2012-11-27 17:17:53|  分类: Java多线程 |  标签: |举报 |字号 订阅

  下载LOFTER 我的照片书  |

服务端原本有个定时任务对一个集合ArrayList 中的消息做处理。 因为考虑到处理消息是先进先出原则,所以优化的时候考虑改用ConcurrentLinkedQueue 当时没仔细深入研究过这个集合就匆匆上线了。结果刚上线第二天就出问题了。服务端一次优化演变成了一个缺陷,还好及时回退了版本,后果才不是很严重。

回退后对ConcurrentLinkedQueue 做了一个简单的测试代码如下:

  1. import java.util.concurrent.ConcurrentLinkedQueue;  
  2. import java.util.concurrent.CountDownLatch;  
  • import java.util.concurrent.ExecutorService;  
  • import java.util.concurrent.Executors;  
  • public class ConcurrentLinkedQueueTest {  
  •     private static ConcurrentLinkedQueue<Integer> queue = new ConcurrentLinkedQueue<Integer>();  
  •     private static int count = 100000;  
  •     private static int count2 = 2// 线程个数   
  •     private static CountDownLatch cd = new CountDownLatch(count2);  
  •     public static void dothis() {  
  •         for (int i = 0; i < count; i++) {  
  •             queue.offer(i);  
  •         }  
  •     }  
  •     public static void main(String[] args) throws InterruptedException {  
  •         long timeStart = System.currentTimeMillis();  
  •         ExecutorService es = Executors.newFixedThreadPool(4);  
  •         ConcurrentLinkedQueueTest.dothis();  
  •         for (int i = 0; i < count2; i++) {  
  •             es.submit(new Poll());  
  •         }  
  •         cd.await();  
  •         System.out.println("cost time "  
  •                 + (System.currentTimeMillis() - timeStart) + "ms");  
  •         es.shutdown();  
  •     }  
  •     static class Poll implements Runnable {  
  •         @Override  
  •         public void run() {  
  • //          while (queue.size()>0) {   
  •             while (!queue.isEmpty()) {  
  •                 System.out.println(queue.poll());  
  •             }  
  •             cd.countDown();  
  •         }  
  •     }  
  • }  
  •  

    运行结果:

    costtime 2360ms

     

    改用while (queue.size()>0)后

    运行结果:

    cost time 46422ms

     

    结果居然相差那么大,看了下ConcurrentLinkedQueue的API 原来.size() 是要遍历一遍集合的,难怪那么,所以尽量要避免用size而改用isEmpty().

    总结了下, 在单位缺乏性能测试下,对自己的编程要求更加要严格,特别是在生产环境下更是要小心谨慎。

      评论这张
     
    阅读(4752)| 评论(0)
    推荐 转载

    历史上的今天

    评论

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

    页脚

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