寫在前面

最近，有不少網友留言提問：在Java的併發程式設計中，有個BlockingQueue，它是個阻塞佇列，為何要在併發程式設計裡使用BlockingQueue呢？好吧，今天，就臨時說一下BlockingQueue吧，不過今天說的不是很深入，後面咱們一起從源頭上深入剖析這個類。

BlockingQueue概述

阻塞佇列，是執行緒安全的。

被阻塞的情況如下：

（1）當佇列滿時，進行入佇列操作
（2）當佇列空時，進行出佇列操作

使用場景如下：

主要在生產者和消費者場景。

BlockingQueue的方法

BlockingQueue 具有 4 組不同的方法用於插入、移除以及對佇列中的元素進行檢查。如果請求的操作不能得到立即執行的話，每個方法的表現也不同。這些方法如下：

	丟擲異常	特殊值	阻塞	超時
插入	add(e)	offer(e)	put(e)	offer(e, time, unit)
移除	remove()	poll()	take()	poll(time, unit)
檢查	element()	peek()	不可用	不可用

​
四組不同的行為方式解釋

• 丟擲異常

如果試圖的操作無法立即執行，拋一個異常。

• 特殊值

如果試圖的操作無法立即執行，返回一個特定的值(常常是 true / false)。

• 阻塞

如果試圖的操作無法立即執行，該方法呼叫將會發生阻塞，直到能夠執行。

• 超時

如果試圖的操作無法立即執行，該方法呼叫將會發生阻塞，直到能夠執行，但等待時間不會超過給定值。返回一個特定值以告知該操作是否成功(典型的是 true / false)。

BlockingQueue的實現類

• ArrayBlockingQueue：有界的阻塞佇列（容量有限，必須在初始化的時候指定容量大小，容量大小指定後就不能再變化），內部實現是一個數組，以FIFO的方式儲存資料，最新插入的物件是尾部，最新移除的物件是頭部。
• DelayQueue：阻塞的是內部元素，DelayQueue中的元素必須實現一個介面——Delayed（存在於J.U.C下）。Delayed介面繼承了Comparable介面，這是因為Delayed介面中的元素需要進行排序，一般情況下，都是按照Delayed介面中的元素過期時間的優先順序進行排序。應用場景主要有：定時關閉連線、快取物件、超時處理等。內部實現使用PriorityQueue和ReentrantLock。
• LinkedBlockingQueue：大小配置是可選的，如果初始化時指定了大小，則是有邊界的；如果初始化時未指定大小，則是無邊界的（其實預設大小是Integer型別的最大值）。內部實現時一個連結串列，以FIFO的方式儲存資料，最新插入的物件是尾部，最新移除的物件是頭部。
• PriorityBlockingQueue：帶優先順序的阻塞佇列，無邊界，但是有排序規則，允許插入空物件(也就是null)。所有插入的物件必須實現Comparable介面，佇列優先順序的排序規則就是按照對Comparable介面的實現來定義的。可以從PriorityBlockingQueue中獲得一個迭代器Iterator，但這個迭代器並不保證按照優先順序的順序進行迭代。
• SynchronousQueue：佇列內部僅允許容納一個元素，當一個執行緒插入一個元素後，就會被阻塞，除非這個元素被另一個執行緒消費。因此，也稱SynchronousQueue為同步佇列。SynchronousQueue是一個無界非快取的佇列。準確的說，它不儲存元素，放入元素只有等待取走元素之後，才能再次放入元素。

寫在最後

如果覺得文章對你有點幫助，請微信搜尋並關注「 冰河技術 」微信公眾號，跟冰河學習高併發程式設計技術。

最後，附上併發程式設計需要掌握的核心技能知識圖，祝大家在學習併發程式設計時，少走彎路。

相關推薦