理解并解决Java并发问题：BlockingQueue示例-蒲公英云

理解并解决Java并发问题：BlockingQueue示例

在Java中，BlockingQueue 是一种线程安全的队列。它可以在元素被添加到队列时阻塞当前的线程，直到队列中有足够的空间可以接受新的元素。

以下是一个使用BlockingQueue的例子：

import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;
public class BlockingQueueExample {
    public static void main(String[] args) {
        // 创建一个容量为10的阻塞队列
        BlockingQueue<Integer> queue = new LinkedBlockingQueue<>(10);
        // 向队列中添加元素，会阻塞当前线程直到有足够的空间
        for (int i = 0; i < 20; i++) {
            try {
                queue.put(i); // 添加元素到队列
                System.out.println("Element " + i + " added to the queue.");
            } catch (InterruptedException e) {
                e.printStackTrace();
                System.out.println("Adding element to the queue interrupted.");
            }
        }
        // 向空队列中添加元素，会立即返回，而不会阻塞线程
        try {
            queue.put(21); // 添加元素到空队列
            System.out.println("Element 21 added to an empty queue.");
        } catch (InterruptedException e) {
            e.printStackTrace();
            System.out.println("Adding element to an empty queue interrupted.");
        }
    }
}