Java中的ConcurrentLinkedQueue使用解析

public class ConcurrentLinkedQueueTest {
    private static final Logger logger = LoggerFactory.getLogger(ConcurrentLinkedQueueTest.class);
    public static void main(String args[]) throws InterruptedException {
        ConcurrentLinkedQueue<String> queue = new ConcurrentLinkedQueue<String>();
        int serviceNum = 10;//服务窗口数
        int perpeoNum = 10000;//买车票人数
        CountDownLatch countDownLatch = new CountDownLatch(serviceNum);//初始值是线程的个数
        //将买票人数放入队列
        for(int i=0; i<perpeoNum; i++){
            queue.add("买票人_" + i);
        }
        //执行10个线程从队列取出买票人
        logger.info("-----开始卖票了--------");
        long start = System.currentTimeMillis();
        ExecutorService service = Executors.newFixedThreadPool(10);
        for(int i=0; i<serviceNum; i++){
            service.submit(new Windows("窗口号_" + i , queue, countDownLatch));
        }
        //等待所有线程都执行完，主线程再执行。
        countDownLatch.await();
		logger.info("-----所有人都买完票了----");
        long time = System.currentTimeMillis() - start;
        logger.info("总消耗时间是：{}",time);
        service.shutdown();
    }
    private static class Windows implements Runnable{
        private String name;
        private ConcurrentLinkedQueue queue;
        private CountDownLatch countDownLatch;
        public Windows(String name, ConcurrentLinkedQueue queue, CountDownLatch countDownLatch){
            this.name = name;
            this.queue = queue;
            this.countDownLatch = countDownLatch;
        }
        @Override
        public void run() {
        //   while (!queue.isEmpty()){
            while(queue.size() > 0){  
                logger.info(queue.poll()  + "---买票完毕---{}", name );
            }
            countDownLatch.countDown();//线程执行完，count值-1
        }
    }
}