Java中常用队列的使用解读

Queue<String> queue = new LinkedList<>();
queue.add("A");
queue.add("B");

System.out.println(queue.peek()); // 输出 A

String element = queue.remove();
System.out.println(element); // 输出 A

Queue<String> deque = new ArrayDeque<>();

deque.add("A");
deque.add("B");

System.out.println(deque.peek()); // 输出 A

deque.addFirst("C"); // 添加到头部
System.out.println(deque.peek()); // 输出 C

String element = deque.remove(); // 移除队头元素 C
System.out.println(element); // 输出 C

Queue<Integer> priorityQueue = new PriorityQueue<>();

priorityQueue.add(3);
priorityQueue.add(1);
priorityQueue.add(2);

System.out.println(priorityQueue.peek()); // 输出 1

int element = priorityQueue.remove();
System.out.println(element); // 输出 1

import java.util.concurrent.LinkedBlockingQueue;

public class BlockingQueueExample {
    public static void main(String[] args) throws InterruptedException {
        BlockingQueue<String> blockingQueue = new LinkedBlockingQueue<>(2);
        
        // 生产者线程
        Thread producerThread = new Thread(() -> {
            try {
                System.out.println("生产者开始生产...");
                blockingQueue.put("Item 1");
                blockingQueue.put("Item 2");
                blockingQueue.put("Item 3"); // 队列已满，阻塞直到有空间
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
                System.out.println("生产者线程被中断...");
            }
        });
        
        // 消费者线程
        Thread consumerThread = new Thread(() -> {
            try {
                System.out.println("消费者开始消费...");
                while (true) {
                    String item = blockingQueue.take();
                    System.out.println("消费了: " + item);
                }
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
                System.out.println("消费者线程被中断...");
            }
        });
        
        producerThread.start();
        consumerThread.start();
    }
}