最近在維護一個java工程,在群組裡面也就聊起來java的優劣!無奈一些Java的終極粉絲,總是號稱性能已經不必C++差,並且很多標準類別庫都是大師級的人寫的,如何如何穩定等等。索性就認真研究一番,他們給我的一項說明就是,在線程之間投遞訊息,用java已經封裝好的BlockingQueue,就夠用了。
既然夠用那就寫程式碼測試嘍,簡簡單單一寫一個小程式做了一番測試:
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;
}
我在上面的測試程式碼中使用的offer 和poll,就看看這兩個實作函數吧,首先是offer