Java 并发集合：阻塞队列集合介绍

在Java中，BlockingQueue是一个线程安全的队列，在处理多线程和并发时特别有用。BlockingQueue接口定义了一组用于线程安全地插入、提取和检查队列元素的方法。如果队列是空的，那么从队列中提取元素的操作将会被阻塞；如果队列是满的，那么插入元素的操作将会被阻塞。

以下是一些常见的BlockingQueue实现及其特性的简单介绍：

1. ArrayBlockingQueue：基于数组的有界阻塞队列。
2. LinkedBlockingQueue：基于链表的可选有界（默认无界）阻塞队列。
3. PriorityBlockingQueue：支持优先级排序的无界阻塞队列。
4. DelayQueue：支持延迟获取的无界阻塞队列。
5. SynchronousQueue：特殊的阻塞队列，每个插入必须等待另一个线程移除，反之亦然。

下面是一个使用ArrayBlockingQueue的简单例子：

import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;
 
public class BlockingQueueExample {
    public static void main(String[] args) throws InterruptedException {
        BlockingQueue<Integer> queue = new ArrayBlockingQueue<>(10);
 
        // 添加元素
        queue.put(1);
        queue.put(2);
 
        // 查看元素，不移除
        System.out.println(queue.peek()); // 输出1
 
        // 添加10个元素，队列满时会阻塞
        for (int i = 0; i < 10; i++) {
            queue.put(i);
        }
 
        // 移除元素
        int element = queue.take();
        System.out.println(element); // 输出0，队列开头的元素
 
        // 迭代队列中的元素
        for (int i : queue) {
            System.out.println(i);
        }
    }
}

在这个例子中，我们创建了一个容量为10的ArrayBlockingQueue，并在其中添加了两个元素。然后我们使用peek方法查看了队列的第一个元素，而不移除它。接下来，我们通过put方法添加了10个元素，因为队列已满，所以这个操作将会阻塞，直到有元素被移除。然后我们使用take方法移除了队列的第一个元素，并打印了它。最后，我们通过迭代器迭代并打印了队列中的剩余元素。