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;//服務窗口數(shù)
        int perpeoNum = 10000;//買車票人數(shù)
        CountDownLatch countDownLatch = new CountDownLatch(serviceNum);//初始值是線程的個數(shù)
        //將買票人數(shù)放入隊列
        for(int i=0; i<perpeoNum; i++){
            queue.add("買票人_" + i);
        }
        //執(zhí)行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));
        }
        //等待所有線程都執(zhí)行完，主線程再執(zhí)行。
        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();//線程執(zhí)行完，count值-1
        }
    }
}