# Java `LinkedBlockingQueue` > 原文： [https://www.programiz.com/java-programming/linkedblockingqueue](https://www.programiz.com/java-programming/linkedblockingqueue) #### 在本教程中，我們將借助示例學習`LinkedBLockingQueue`類及其方法。 Java `Collections`框架的`LinkedBlockingQueue`類使用鏈表提供阻塞隊列實現。 它實現了 [Java `BlockingQueue`接口](/java-programming/blockingqueue "Java BlockingQueue Interface")。  * * * ## 創建`LinkedBlockingQueue` 為了創建鏈接的阻塞隊列，我們??必須導入`java.util.concurrent.LinkedBlockingQueue`包。 這是我們如何在 Java 中創建鏈接的阻塞隊列的方法： **1.沒有初始容量** ```java LinkedBlockingQueue<Type> animal = new LinkedBlockingQueue<>(); ``` 在此，默認初始容量為`2 ^ 31 -1`。 **2.具有初始容量** ```java LinkedBlockingQueue<Type> animal = new LinkedBlockingQueue<>(int capacity); ``` 這里， * `Type` - 鏈接的阻塞隊列的類型 * `capcity` - 鏈接的阻塞隊列的大小 例如， ```java // Creating String type LinkedBlockingQueue with size 5 LinkedBlockingQueue<String> animals = new LinkedBlockingQueue<>(5); // Creating Integer type LinkedBlockingQueue with size 5 LinkedBlockingQueue<Integer> age = new LinkedBlockingQueue<>(5); ``` **注意**：不必提供鏈表的大小。 * * * ## `LinkedBlockingQueue`的方法 `LinkedBlockingQueue`類提供[`BlockingQueue`接口](/java-programming/blockingqueue "Java BlockingQueue Interface")中所有方法的實現。 這些方法用于從鏈接的阻塞隊列中插入，訪問和刪除元素。 另外，我們還將學習兩種方法`put()`和`take()`，它們支持鏈接的阻塞隊列中的阻塞操作。 這兩種方法將鏈接的阻塞隊列與其他典型隊列區分開來。 * * * ### 插入元素 * `add()` - 將指定的元素插入鏈接的阻塞隊列。 如果隊列已滿，它將引發異常。 * `offer()` - 將指定的元素插入鏈接的阻塞隊列。 如果隊列已滿，則返回`false`。 例如： ```java import java.util.concurrent.LinkedBlockingQueue; class Main { public static void main(String[] args) { LinkedBlockingQueue<String> animals = new LinkedBlockingQueue<>(5); // Using add() animals.add("Dog"); animals.add("Cat"); // Using offer() animals.offer("Horse"); System.out.println("LinkedBlockingQueue: " + animals); } } ``` **輸出** ```java LinkedBlockingQueue: [Dog, Cat, Horse] ``` * * * ### 訪問元素 * `peek()` - 從鏈接的阻塞隊列的最前面返回一個元素。 如果隊列為空，則返回`null`。 * `iterator()` - 返回一個迭代器對象，以按順序訪問鏈接的阻塞隊列中的元素。 如果隊列為空，則拋出異常。 我們必須導入`java.util.Iterator`包才能使用它。 例如： ```java import java.util.concurrent.LinkedBlockingQueue; import java.util.Iterator; class Main { public static void main(String[] args) { LinkedBlockingQueue<String> animals = new LinkedBlockingQueue<>(5); // Add elements animals.add("Dog"); animals.add("Cat"); animals.add("Horse"); System.out.println("LinkedBlockingQueue: " + animals); // Using peek() String element = animals.peek(); System.out.println("Accessed Element: " + element); // Using iterator() Iterator<String> iterate = animals.iterator(); System.out.print("LinkedBlockingQueue Elements: "); while(iterate.hasNext()) { System.out.print(iterate.next()); System.out.print(", "); } } } ``` **輸出**： ```java LinkedBlockingQueue: [Dog, Cat, Horse] Accessed Element: Dog LinkedBlockingQueue Elements: Dog, Cat, Horse, ``` * * * ### 刪除元素 * `remove()` - 返回指定的元素并將其從鏈接的阻塞隊列中移除。 如果隊列為空，則拋出異常。 * `poll()` - 返回指定的元素并將其從鏈接的阻塞隊列中移除。 如果隊列為空，則返回`null`。 * `clear()` - 從鏈接的阻塞隊列中刪除所有元素。 例如： ```java import java.util.concurrent.LinkedBlockingQueue; class Main { public static void main(String[] args) { LinkedBlockingQueue<String> animals = new LinkedBlockingQueue<>(5); animals.add("Dog"); animals.add("Cat"); animals.add("Horse"); System.out.println("LinkedBlockingQueue " + animals); // Using remove() String element1 = animals.remove(); System.out.println("Removed Element:"); System.out.println("Using remove(): " + element1); // Using poll() String element2 = animals.poll(); System.out.println("Using poll(): " + element2); // Using clear() animals.clear(); System.out.println("Updated LinkedBlockingQueue " + animals); } } ``` **輸出**： ```java LinkedBlockingQueue: [Dog, Cat, Horse] Removed Elements: Using remove(): Dog Using poll(): Cat Updated LinkedBlockingQueue: [] ``` * * * ## `put()`和`take()`方法 在多線程進程中，我們可以使用`put()`和`take()`阻止一個線程的操作，使其與另一個線程同步。 這些方法將等待直到可以成功執行。 * * * ### `put()`方法 要將指定的元素插入到鏈接的阻塞隊列的末尾，我們使用`put()`方法。 如果鏈接的阻塞隊列已滿，它將等待，直到鏈接的阻塞隊列中有足夠的空間來插入元素。 例如： ```java import java.util.concurrent.LinkedBlockingQueue; class Main { public static void main(String[] args) { LinkedBlockingQueue<String> animals = new LinkedBlockingQueue<>(5); try { // Add elements to animals animals.put("Dog"); animals.put("Cat"); System.out.println("LinkedBlockingQueue: " + animals); } catch(Exception e) { System.out.println(e); } } } ``` **輸出**： ```java LinkedBlockingQueue: [Dog, Cat] ``` 在此，如果`InterruptedException`方法在等待時被中斷，則可能會拋出`InterruptedException`。 因此，我們必須將其封裝在`try..catch`塊中。 * * * ### `take()`方法 要從鏈接的阻塞隊列的前面返回并刪除一個元素，我們可以使用`take()`方法。 如果鏈接的阻塞隊列為空，它將等待，直到要刪除的鏈接阻塞隊列中的元素為止。 例如： ```java import java.util.concurrent.LinkedBlockingQueue; class Main { public static void main(String[] args) { LinkedBlockingQueue<String> animals = new LinkedBlockingQueue<>(5); try { //Add elements to animals animals.put("Dog"); animals.put("Cat"); System.out.println("LinkedBlockingQueue: " + animals); // Remove an element String element = animals.take(); System.out.println("Removed Element: " + element); System.out.println("New LinkedBlockingQueue: " + animals); } catch(Exception e) { System.out.println(e); } } } ``` **輸出**： ```java LinkedBlockingQueue: [Dog, Cat] Removed Element: Dog New LinkedBlockingQueue: [Cat] ``` 在這里，如果`take()`方法在等待時被中斷，則會拋出`InterrupedException`。 因此，我們必須將其封裝在[H??TG2]塊內。 * * * ## 其他方法 | 方法 | 內容描述 | | --- | --- | | `contains(element)` | 在鏈接的阻塞隊列中搜索指定的元素。 如果找到該元素，則返回`true`，否則返回`false`。 | | `size()` | 返回鏈接的阻塞隊列的長度。 | | `toArray()` | 將鏈接的阻塞隊列轉換為數組并返回該數組。 | | `toString()` | 將鏈接的阻塞隊列轉換為字符串 | * * * ## 為什么要使用`LinkedBlockingQueue`？ `LinkedBlockingQueue`使用鏈表作為其內部存儲。 它被視為**線程安全的**集合。 因此，它通常用于多線程應用中。 假設一個線程正在將元素插入隊列，而另一個線程正在從隊列中刪除元素。 現在，如果第一個線程比第二個線程慢，則鏈接的阻塞隊列可使第二個線程等待，直到第一個線程完成其操作。