Java多線程總結之Queue

　　上個星期總結了一下synchronized相關的知識，這次將Queue相關的知識總結一下，和朋友們分享。

　　在Java多線程應用中，隊列的使用率很高，多數生產消費模型的首選數據結構就是隊列。Java提供的線程安全的Queue可以分為阻塞隊列和非阻塞隊列，其中阻塞隊列的典型例子是BlockingQueue，非阻塞隊列的典型例子是ConcurrentLinkedQueue，在實際應用中要根據實際需要選用阻塞隊列或者非阻塞隊列。

　　注：什么叫線程安全？這個首先要明確。線程安全的類 ，指的是類內共享的全局變量的訪問必須保證是不受多線程形式影響的。如果由于多線程的訪問（比如修改、遍歷、查看）而使這些變量結構被破壞或者針對這些變量操作的原子性被破壞，則這個類就不是線程安全的。

　　今天就聊聊這兩種Queue，本文分為以下兩個部分，用分割線分開：

　　BlockingQueue

　　ConcurrentLinkedQueue，非阻塞算法

　　首先來看看BlockingQueue：

　　Queue是什么就不需要多說了吧，一句話：隊列是先進先出。相對的，棧是后進先出。如果不熟悉的話先找本基礎的數據結構的書看看吧。

　　BlockingQueue，顧名思義，“阻塞隊列”：可以提供阻塞功能的隊列。

　　首先，看看BlockingQueue提供的常用方法：　　

　　從上表可以很明顯看出每個方法的作用，這個不用多說。我想說的是：

　　add（e） remove（） element（） 方法不會阻塞線程。當不滿足約束條件時，會拋出IllegalStateException 異常。例如：當隊列被元素填滿后，再調用add（e），則會拋出異常。

　　offer（e） poll（） peek（） 方法即不會阻塞線程，也不會拋出異常。例如：當隊列被元素填滿后，再調用offer（e），則不會插入元素，函數返回false。

　　要想要實現阻塞功能，需要調用put（e） take（） 方法。當不滿足約束條件時，會阻塞線程。

　　好，上點源碼你就更明白了。以ArrayBlockingQueue類為例：

　　對于第一類方法，很明顯如果操作不成功就拋異常。而且可以看到其實調用的是第二類的方法，為什么？因為第二類方法返回boolean啊。

　　Java代碼

　　public boolean add（E e） {

　　if （offer（e））

　　return true;

　　else

　　throw new IllegalStateException（“Queue full”）;//隊列已滿，拋異常

　　}

　　public E remove（） {

　　E x = poll（）;

　　if （x ！= null）

　　return x;

　　else

　　throw new NoSuchElementException（）;//隊列為空，拋異常

　　}

　　對于第二類方法，很標準的ReentrantLock使用方式（不熟悉的朋友看一下我上一篇帖子吧），另外對于insert和extract的實現沒啥好說的。

　　注：先不看阻塞與否，這ReentrantLock的使用方式就能說明這個類是線程安全類。

　　Java代碼

　　public boolean offer（E e） {