public static void testConcurrentLinkedQueue(){
		
		ConcurrentLinkedQueue<String> queue=new ConcurrentLinkedQueue();
		
		for (int i = 0; i < 10; i++) {
			queue.offer("a"+i);
		}
		while(true){
			
			if(!queue.isEmpty()){
				String str=queue.poll();
				System.out.println(str);
			}
			try {
				TimeUnit.SECONDS.sleep(1);
			} catch (InterruptedException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
			
		
			/*else{
				System.out.println(queue);
			}*/
		}
		
	}