ConcurrentLinkedQueue

因為ConcurrentLinkedQueue是線程序安全的并且是針對并發(fā)的

主類

Java代碼 ?

public?class?conn{??

????public?static?void?main(String[]?args)?throws?Exception{??

????????Queue<String>?queue=new?ConcurrentLinkedQueue<String>();??

????????for(int?i=0;i<1000000;i++){??

???????????queue.add(String.valueOf(i));??

????????}??

????????int?num=10;//線程人個數??

????????for(int?i=0;i<num;i++){??

???????????new?ThreadConn(queue);??

????????}??

??

????}??

}??

線程類

Java代碼 ?

public?class?ThreadConn?implements?Runnable{??

????Queue<String>?queue;??

????public?ThreadConn(Queue<String>?queue){??

????????this.queue=queue;??

????????Thread?thread=new?Thread(this);??

????????thread.start();??

????}??

????public?void?run(){??

????????try{??

????????????long?sd=new?Date().getTime();??

????????????while(queue.poll()!=null){??

??????????????????????????//這里是業(yè)務邏輯??

????????????}??

????????????System.out.println?(sn-sd);??

????????}catch(Exception?e){??

????????????e.printStackTrace();??

????????}??

????}??

}?

總結

以上是生活随笔為你收集整理的ConcurrentLinkedQueue的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。