java中queue的使用

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

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

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

remove、element、offer 、poll、peek 實際上是屬于Queue接口。 

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

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

還有帶超時的offer和poll方法變種，例如，下面的調用：
boolean success = q.offer(x,100,TimeUnit.MILLISECONDS);
嘗試在100毫秒內向隊列尾部插入1個元素。如果成功，立即返回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是1個帶優先級的 隊列，而不是先進先出隊列。元素按優先級順序被移除，該隊列也沒有上限（看了1下源碼，PriorityBlockingQueue是對 PriorityQueue的再次包裝，是基于堆數據結構的，而PriorityQueue是沒有容量限制的，與ArrayList1樣，所以在優先阻塞 隊列上put時是不會受阻的。雖然此隊列邏輯上是無界的，但是由于資源被耗盡，所以試圖履行添加操作可能會致使 OutOfMemoryError），但是如果隊列為空，那末取元素的操作take就會阻塞，所以它的檢索操作take是受阻的。另外，往入該隊列中的元 素要具有比較能力。

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

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

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

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.         //只啟動1個線程來搜索目錄  
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. }  

生活不易，碼農辛苦
如果您覺得本網站對您的學習有所幫助,可以手機掃描二維碼進行捐贈