谈谈java的BlockingQueue

最近在维护一个java工程,香港虚拟主机,虚拟主机,在群里面也就聊起来java的优劣!无奈一些Java的终极粉丝,总是号称性能已经不必C++差,并且很多标准类库都是大师级的人写的,如何如何稳定等等。索性就认真研究一番,他们给我的一项说明就是,在线程之间投递消息,用java已经封装好的BlockingQueue,就足够用了。

既然足够用那就写代码测试喽,简简单单写一个小程序做了一番测试:

//默认包import java.util.concurrent.*;import base.MyRunnable;public class Test{public static void main(String[] args){BlockingQueue<Integer> queue = new LinkedBlockingQueue<Integer>();java.lang.Runnable r = new MyRunnable(queue);Thread t = new Thread(r);t.start();while(true){try{while(true){for(int i =0;i < 10000;i++){queue.offer(i);}}}catch ( Exception e){e.printStackTrace();}}}}//需要添加的包package base;import java.lang.Runnable;import java.util.concurrent.*;import java.util.*;public class MyRunnable implements Runnable{public MyRunnable(BlockingQueue<Integer> queue){this.queue = queue;}public void run(){Date d = new Date();long starttime = d.getTime();System.err.println(starttime);int count = 0;while(true){try{Integer i = this.queue.poll();if(i != null){count ++;}if(count == 100000){Date e = new Date();long endtime = e.getTime();System.err.println(count);System.err.println(endtime);System.err.print(endtime – starttime);break;}}catch (Exception e){}}}private BlockingQueue<Integer> queue;},免备案空间每一幢房子都有一种不同的颜色,

谈谈java的BlockingQueue

相关文章:

你感兴趣的文章:

标签云: