java中queue的使用

Queue接口與List、Set同一級別，都是繼承了Collection接口。LinkedList實現了Queue接 口。Queue接口窄化了對LinkedList的方法的訪問權限（即在方法中的參數類型如果是Queue時，就完全只能訪問Queue接口所定義的方法 了，而不能直接訪問 LinkedList的非Queue的方法），以使得只有恰當的方法才可以使用。BlockingQueue 繼承了Queue接口。

 

隊列是一種數據結構．它有兩個基本操作：在隊列尾部加人一個元素，和從隊列頭部移除一個元素就是說，隊列以一種先進先出的方式管理數據，如果你試圖向一個 已經滿了的阻塞隊列中添加一個元素或者是從一個空的阻塞隊列中移除一個元索，將導致線程阻塞．在多線程進行合作時，阻塞隊列是很有用的工具。工作者線程可 以定期地把中間結果存到阻塞隊列中而其他工作者線線程把中間結果取出並在將來修改它們。隊列會自動平衡負載。如果第一個線程集運行得比第二個慢，則第二個 線程集在等待結果時就會阻塞。如果第一個線程集運行得快，那么它將等待第二個線程集趕上來。下表顯示了jdk1.5中的阻塞隊列的操作：

 

add        增加一個元索                     如果隊列已滿，則拋出一個IIIegaISlabEepeplian異常
remove   移除並返回隊列頭部的元素    如果隊列為空，則拋出一個NoSuchElementException異常
element  返回隊列頭部的元素             如果隊列為空，則拋出一個NoSuchElementException異常
offer       添加一個元素並返回true       如果隊列已滿，則返回false
poll         移除並返問隊列頭部的元素    如果隊列為空，則返回null
peek       返回隊列頭部的元素             如果隊列為空，則返回null
put         添加一個元素                      如果隊列滿，則阻塞
take        移除並返回隊列頭部的元素     如果隊列為空，則阻塞

 

remove、element、offer 、poll、peek 其實是屬於Queue接口。 

 

阻塞隊列的操作可以根據它們的響應方式分為以下三類：aad、removee和element操作在你試圖為一個已滿的隊列增加元素或從空隊列取得元素時 拋出異常。當然，在多線程程序中，隊列在任何時間都可能變成滿的或空的，所以你可能想使用offer、poll、peek方法。這些方法在無法完成任務時 只是給出一個出錯示而不會拋出異常。

 

注意：poll和peek方法出錯進返回null。因此，向隊列中插入null值是不合法的。

 

還有帶超時的offer和poll方法變種，例如，下面的調用：
boolean success = q.offer(x,100,TimeUnit.MILLISECONDS);
嘗試在100毫秒內向隊列尾部插入一個元素。如果成功，立即返回true；否則，當到達超時進，返回false。同樣地，調用：
Object head = q.poll(100, TimeUnit.MILLISECONDS);
如果在100毫秒內成功地移除了隊列頭元素，則立即返回頭元素；否則在到達超時時，返回null。

 

最后，我們有阻塞操作put和take。put方法在隊列滿時阻塞，take方法在隊列空時阻塞。

 

java.ulil.concurrent包提供了阻塞隊列的4個變種。默認情況下，LinkedBlockingQueue的容量是沒有上限的（說的不准確，在不指定時容量為Integer.MAX_VALUE，不要然的話在put時怎么會受阻呢），但是也可以選擇指定其最大容量，它是基於鏈表的隊列，此隊列按 FIFO（先進先出）排序元素。

ArrayBlockingQueue在構造時需要指定容量， 並可以選擇是否需要公平性，如果公平參數被設置true，等待時間最長的線程會優先得到處理（其實就是通過將ReentrantLock設置為true來 達到這種公平性的：即等待時間最長的線程會先操作）。通常，公平性會使你在性能上付出代價，只有在的確非常需要的時候再使用它。它是基於數組的阻塞循環隊 列，此隊列按 FIFO（先進先出）原則對元素進行排序。

PriorityBlockingQueue是一個帶優先級的 隊列，而不是先進先出隊列。元素按優先級順序被移除，該隊列也沒有上限（看了一下源碼，PriorityBlockingQueue是對 PriorityQueue的再次包裝，是基於堆數據結構的，而PriorityQueue是沒有容量限制的，與ArrayList一樣，所以在優先阻塞 隊列上put時是不會受阻的。雖然此隊列邏輯上是無界的，但是由於資源被耗盡，所以試圖執行添加操作可能會導致 OutOfMemoryError），但是如果隊列為空，那么取元素的操作take就會阻塞，所以它的檢索操作take是受阻的。另外，往入該隊列中的元 素要具有比較能力。

最后，DelayQueue（基於PriorityQueue來實現的）是一個存放Delayed 元素的無界阻塞隊列，只有在延遲期滿時才能從中提取元素。該隊列的頭部是延遲期滿后保存時間最長的 Delayed 元素。如果延遲都還沒有期滿，則隊列沒有頭部，並且poll將返回null。當一個元素的 getDelay(TimeUnit.NANOSECONDS) 方法返回一個小於或等於零的值時，則出現期滿，poll就以移除這個元素了。此隊列不允許使用 null 元素。 下面是延遲接口：

Java代碼

1. public interface Delayed extends Comparable<Delayed> {  
2.      long getDelay(TimeUnit unit);  
3. }  

放入DelayQueue的元素還將要實現compareTo方法，DelayQueue使用這個來為元素排序。

 

下面的實例展示了如何使用阻塞隊列來控制線程集。程序在一個目錄及它的所有子目錄下搜索所有文件，打印出包含指定關鍵字的文件列表。從下面實例可以看出，使用阻塞隊列兩個顯著的好處就是：多線程操作共同的隊列時不需要額外的同步，另外就是隊列會自動平衡負載，即那邊（生產與消費兩邊）處理快了就會被阻塞掉，從而減少兩邊的處理速度差距。下面是具體實現：

Java代碼

1. public class BlockingQueueTest {  
2.     public static void main(String[] args) {  
3.         Scanner in = new Scanner(System.in);  
4.         System.out.print("Enter base directory (e.g. /usr/local/jdk5.0/src): ");  
5.         String directory = in.nextLine();  
6.         System.out.print("Enter keyword (e.g. volatile): ");  
7.         String keyword = in.nextLine();  
8.   
9.         final int FILE_QUEUE_SIZE = 10;// 阻塞隊列大小  
10.         final int SEARCH_THREADS = 100;// 關鍵字搜索線程個數  
11.   
12.         // 基於ArrayBlockingQueue的阻塞隊列  
13.         BlockingQueue<File> queue = new ArrayBlockingQueue<File>(  
14.                 FILE_QUEUE_SIZE);  
15.   
16.         //只啟動一個線程來搜索目錄  
17.         FileEnumerationTask enumerator = new FileEnumerationTask(queue,  
18.                 new File(directory));  
19.         new Thread(enumerator).start();  
20.           
21.         //啟動100個線程用來在文件中搜索指定的關鍵字  
22.         for (int i = 1; i <= SEARCH_THREADS; i++)  
23.             new Thread(new SearchTask(queue, keyword)).start();  
24.     }  
25. }  
26. class FileEnumerationTask implements Runnable {  
27.     //啞元文件對象，放在阻塞隊列最后，用來標示文件已被遍歷完  
28.     public static File DUMMY = new File("");  
29.   
30.     private BlockingQueue<File> queue;  
31.     private File startingDirectory;  
32.   
33.     public FileEnumerationTask(BlockingQueue<File> queue, File startingDirectory) {  
34.         this.queue = queue;  
35.         this.startingDirectory = startingDirectory;  
36.     }  
37.   
38.     public void run() {  
39.         try {  
40.             enumerate(startingDirectory);  
41.             queue.put(DUMMY);//執行到這里說明指定的目錄下文件已被遍歷完  
42.         } catch (InterruptedException e) {  
43.         }  
44.     }  
45.   
46.     // 將指定目錄下的所有文件以File對象的形式放入阻塞隊列中  
47.     public void enumerate(File directory) throws InterruptedException {  
48.         File[] files = directory.listFiles();  
49.         for (File file : files) {  
50.             if (file.isDirectory())  
51.                 enumerate(file);  
52.             else  
53.                 //將元素放入隊尾，如果隊列滿，則阻塞  
54.                 queue.put(file);  
55.         }  
56.     }  
57. }  
58. class SearchTask implements Runnable {  
59.     private BlockingQueue<File> queue;  
60.     private String keyword;  
61.   
62.     public SearchTask(BlockingQueue<File> queue, String keyword) {  
63.         this.queue = queue;  
64.         this.keyword = keyword;  
65.     }  
66.   
67.     public void run() {  
68.         try {  
69.             boolean done = false;  
70.             while (!done) {  
71.                 //取出隊首元素，如果隊列為空，則阻塞  
72.                 File file = queue.take();  
73.                 if (file == FileEnumerationTask.DUMMY) {  
74.                     //取出來后重新放入，好讓其他線程讀到它時也很快的結束  
75.                     queue.put(file);  
76.                     done = true;  
77.                 } else  
78.                     search(file);  
79.             }  
80.         } catch (IOException e) {  
81.             e.printStackTrace();  
82.         } catch (InterruptedException e) {  
83.         }  
84.     }  
85.     public void search(File file) throws IOException {  
86.         Scanner in = new Scanner(new FileInputStream(file));  
87.         int lineNumber = 0;  
88.         while (in.hasNextLine()) {  
89.             lineNumber++;  
90.             String line = in.nextLine();  
91.             if (line.contains(keyword))  
92.                 System.out.printf("%s:%d:%s%n", file.getPath(), lineNumber,  
93.                         line);  
94.         }  
95.         in.close();  
96.     }  
97. }