可以使用Java中的BlockingQueue接口來實現阻塞隊列。
首先，需要導入java.util.concurrent包，因為BlockingQueue接口是該包中的一部分。
然后，可以選擇合適的阻塞隊列實現類。常見的阻塞隊列實現類有ArrayBlockingQueue、LinkedBlockingQueue和SynchronousQueue等。
以下是一個使用ArrayBlockingQueue實現阻塞隊列的示例代碼：
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;
public class BlockingQueueExample {
public static void main(String[] args) {
// 創建一個容量為10的阻塞隊列
BlockingQueue<Integer> queue = new ArrayBlockingQueue<>(10);
// 創建一個生產者線程
Thread producerThread = new Thread(() -> {
try {
// 生產1到10的數字，并將其放入隊列
for (int i = 1; i <= 10; i++) {
queue.put(i);
System.out.println("Produced: " + i);
Thread.sleep(1000);
}
} catch (InterruptedException e) {
e.printStackTrace();
}
});
// 創建一個消費者線程
Thread consumerThread = new Thread(() -> {
try {
// 從隊列中取出數字并消費
while (true) {
int num = queue.take();
System.out.println("Consumed: " + num);
Thread.sleep(2000);
}
} catch (InterruptedException e) {
e.printStackTrace();
}
});
// 啟動生產者和消費者線程
producerThread.start();
consumerThread.start();
}
}
在以上示例代碼中，創建了一個容量為10的ArrayBlockingQueue對象，然后創建了一個生產者線程和一個消費者線程。生產者線程會不斷生產數字并放入隊列中，消費者線程會從隊列中取出數字并消費。如果隊列已滿，生產者線程會被阻塞直到有空間可用；如果隊列為空，消費者線程會被阻塞直到隊列中有元素可取。
