阻塞佇列

阻塞佇列與普通佇列的區別在於當佇列是空時從佇列中獲取元素的操作將會被阻塞，或者當佇列是滿時往佇列裡新增元素的操作會被阻塞。試圖從空的阻塞佇列中獲取元素的執行緒將會被阻塞，直到其他的執行緒往空的佇列插入新的元素，同樣試圖往已滿的阻塞佇列中新增新元素的執行緒同樣也會被阻塞直到其他的執行緒使佇列重新變得空閒起來

BlockingQueue的操作方法

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

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

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

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

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

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

BlockingQueue幾種子類實現

3.1 ArrayBlockingQueue:一個有界的阻塞佇列，其內部實現是將物件放到一個數組裡，有界也就意味著它不能夠儲存無限多數量的元素，它有一個同一時間能夠儲存元素數量的上限(因為它是基於陣列實現的，一旦初始化大小就無法修改)

3.2 DelayQueue:對元素進行持有直到一個特定的延遲到期，注入其中的元素必須實現java.util.concurrent.Delayed介面

3.3 LinkedBlockingQueue:內部以一個鏈式結構(連結節點)對其元素進行儲存，如果需要的話這一鏈式結構可以選擇一個上限，如果沒有定義上限將使用Integer.MAX_VALUE作為上限

3.4 PriorityBlockingQueue:一個無界的併發佇列，它使用了和類java.util.PriorityQueue一樣的排序規則，你無法向這個佇列中插入null值，所有插入到PriorityBlockingQueue的元素必須實現java.lang.Comparable介面。因此該佇列中元素的排序就取決於你自己的Comparable實現

3.5 SynchronousQueue:一個特殊的佇列，它的內部同時只能夠容納單個元素，如果該佇列已有一元素的話試圖向佇列中插入一個新元素的執行緒將會阻塞，直到另一個執行緒將該元素從佇列中抽走，同樣如果該佇列為空試圖向佇列中抽取一個元素的執行緒將會阻塞，直到另一個執行緒向佇列中插入了一條新的元素

優先順序佇列PriorityBlockingQueue

這裡詳細講一下PriorityBlockingQueue，因為在實際需求中可能會遇到希望後入隊的物件先出隊，面對這種需求我首先想到的是能不能在佇列指定位置新增元素來控制出隊的順序，遺憾佇列是線性結構只能在隊尾位置進行插入元素，隊頭位置插入元素，但是PriorityBlockingQueue可能通過實現Comparable介面來修改出隊優先順序。示例程式碼如下:

public class ThreadExample20 {
    public static void main(String[] args) {
        Comparator<Integer> comparator = new Comparator<Integer>() {
            public int compare(Integer param， Integer param2) {
                if (param > param2) {
                    return 1;
                } else if (param < param2) {
                    return -1;
                } else {
                    return 0;
                }
            }
        };

        BlockingQueue<Integer> blockingQueue = new PriorityBlockingQueue<>(5， comparator);

        try {
            blockingQueue.put(1);
            blockingQueue.put(23);
            blockingQueue.put(56);
            blockingQueue.put(15);
            blockingQueue.put(8);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

        while (true) {
            try {
                System.out.println(blockingQueue.take());
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}

程式執行結果:
1
8
15
23
56