Java中的ConcurrentLinkedQueue使用解析

更新時間：2023年12月28日 09:30:30 作者：小宇宙121

這篇文章主要介紹了Java中的ConcurrentLinkedQueue使用解析,一個基于鏈接節(jié)點的無界線程安全隊列,此隊列按照 FIFO(先進先出)原則對元素進行排序,隊列的頭部是隊列中時間最長的元素,需要的朋友可以參考下

定義

一個基于鏈接節(jié)點的無界線程安全隊列。此隊列按照 FIFO（先進先出）原則對元素進行排序。

隊列的頭部是隊列中時間最長的元素。

隊列的尾部是隊列中時間最短的元素。新的元素插入到隊列的尾部，隊列獲取操作從隊列頭部獲得元素。

當多個線程共享訪問一個公共 collection 時，ConcurrentLinkedQueue 是一個恰當?shù)倪x擇。

此隊列不允許使用 null 元素。

函數(shù)

offer(E e) 將指定元素插入此隊列的尾部。
poll() 獲取并移除此隊列的頭，如果此隊列為空，則返回 null
add() 與offer(E e)完全一樣，都是往隊列尾部添加元素
peek() 獲取但不移除此隊列的頭；如果此隊列為空，則返回 null
remove(Object o) 從隊列中移除指定元素的單個實例（如果存在）
contains(Object o) 如果此隊列包含指定元素，則返回 true
toArray() 返回以恰當順序包含此隊列所有元素的數(shù)組
toArray(T[] a) 返回以恰當順序包含此隊列所有元素的數(shù)組；返回數(shù)組的運行時類型是指定數(shù)組的運行時類型
size() 返回此隊列中的元素數(shù)量
isEmpty 返回隊列是否為空

注意：當需要判斷隊列是否有值時，推薦使用isEmpty()，size()的時間復(fù)雜度是o(n)，當數(shù)據(jù)量很大時，會比isEmpty()消耗明顯多的時間。

下面比較一下isEmpty()和size()耗時：

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;//服務(wù)窗口數(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
        }
    }
}

執(zhí)行結(jié)果：使用size()，耗時511ms；使用isEmpty()，耗時125ms；所以優(yōu)先使用isEmpty()；