在Java中,可以使用BlockingQueue
接口來實現阻塞隊列。BlockingQueue
接口繼承自Queue
接口,它提供了一種線程安全的隊列實現,支持在隊列為空時等待元素被添加,或者在隊列已滿時等待空間被釋放。
常用的BlockingQueue
實現類包括ArrayBlockingQueue
、LinkedBlockingQueue
、PriorityBlockingQueue
等。
以下是一個使用ArrayBlockingQueue
實現阻塞隊列的示例:
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;
public class BlockingQueueExample {
public static void main(String[] args) {
BlockingQueue<Integer> queue = new ArrayBlockingQueue<>(10);
// 生產者線程
Thread producer = new Thread(() -> {
try {
for (int i = 0; i < 10; i++) {
queue.put(i); // 向隊列中添加元素
System.out.println("Produced: " + i);
}
} catch (InterruptedException e) {
e.printStackTrace();
}
});
// 消費者線程
Thread consumer = new Thread(() -> {
try {
for (int i = 0; i < 10; i++) {
int value = queue.take(); // 從隊列中取出元素
System.out.println("Consumed: " + value);
}
} catch (InterruptedException e) {
e.printStackTrace();
}
});
producer.start();
consumer.start();
}
}
在上面的示例中,生產者線程向ArrayBlockingQueue
中添加元素,消費者線程從隊列中取出元素。如果隊列已滿或者為空時,線程會被阻塞,直到隊列中有空間或者有元素可取。