因为ConcurrentLinkedQueue是线程序安全的并且是针对并发的

主类

线程类

1. public class ThreadConn implements Runnable{  
2.     Queue<String> queue;  
3.     public ThreadConn(Queue<String> queue){  
4.         this.queue=queue;  
5.         Thread thread=new Thread(this);  
6.         thread.start();  
7.     }  
8.     public void run(){  
9.         try{  
10.             long sd=new Date().getTime();  
11.             while(queue.poll()!=null){  
12.                           //这里是业务逻辑  
13.             }  
14.             System.out.println (sn-sd);  
15.         }catch(Exception e){  
16.             e.printStackTrace();  
17.         }  
18.     }  
19. }