java基础-Java Queue 接口-编程实验室

Queue 是 Java 集合框架中的一个重要接口，位于java.util包中，它表示一个先进先出（FIFO）的队列数据结构。Queue 接口继承了 Collection 接口，并定义了一组专门用于队列操作的方法。

Queue 接口的主要特点

先进先出(FIFO)：元素按照添加顺序被移除
可选操作：某些方法可能抛出异常或返回特殊值
双端队列支持：可以通过 Deque 接口实现双端队列功能

主要方法

1. 插入操作

boolean add(E e)- 添加元素，如果队列已满则抛出异常
boolean offer(E e)- 添加元素，如果队列已满返回 false

2. 移除操作

E remove()- 移除并返回队首元素，如果队列为空则抛出异常
E poll()- 移除并返回队首元素，如果队列为空返回 null

3. 检查操作

E element()- 返回队首元素但不移除，如果队列为空则抛出异常
E peek()- 返回队首元素但不移除，如果队列为空返回 null

常用实现类

Java 提供了多个 Queue 接口的实现类：

LinkedList：实现了 List 和 Deque 接口，可以作为队列使用

import java.util.LinkedList; import java.util.Queue; Queue<String> queue = new LinkedList<>(); queue.add("A"); queue.add("B"); queue.add("C"); System.out.println(queue.poll()); // 输出: A System.out.println(queue.peek()); // 输出: B

PriorityQueue：基于优先级堆的无界优先级队列

import java.util.PriorityQueue; import java.util.Queue; Queue<Integer> priorityQueue = new PriorityQueue<>(); priorityQueue.offer(5); priorityQueue.offer(1); priorityQueue.offer(3); // 元素按优先级顺序出队 while (!priorityQueue.isEmpty()) { System.out.println(priorityQueue.poll()); // 输出: 1, 3, 5 }

ArrayDeque：基于数组的双端队列实现

import java.util.ArrayDeque; import java.util.Queue; Queue<String> deque = new ArrayDeque<>(); deque.offer("X"); deque.offer("Y"); deque.offer("Z"); System.out.println(deque.poll()); // 输出: X

ConcurrentLinkedQueue：线程安全的无界非阻塞队列

Queue<String> concurrentQueue = new ConcurrentLinkedQueue<>();

BlockingQueue 接口的实现（如 ArrayBlockingQueue, LinkedBlockingQueue）：线程安全的有界阻塞队列

使用示例

import java.util.LinkedList; import java.util.Queue; public class QueueExample { public static void main(String[] args) { // 创建队列 Queue<String> queue = new LinkedList<>(); // 添加元素 queue.add("First"); queue.offer("Second"); // 查看头部元素 System.out.println("Head of queue: " + queue.peek()); // 移除元素 System.out.println("Removed: " + queue.remove()); System.out.println("Removed: " + queue.poll()); // 检查队列是否为空 System.out.println("Is queue empty? " + queue.isEmpty()); } }

与 Deque 接口的关系

Deque（双端队列）接口扩展了 Queue 接口，提供了在队列头部和尾部都能进行插入和删除操作的方法。常用的实现类有 ArrayDeque 和 LinkedList。

阻塞队列

Java 还提供了 BlockingQueue 接口（在 java.util.concurrent 包中），它支持阻塞操作，常用于生产者-消费者模式：

import java.util.concurrent.ArrayBlockingQueue; import java.util.concurrent.BlockingQueue; public class BlockingQueueExample { public static void main(String[] args) { BlockingQueue<Integer> blockingQueue = new ArrayBlockingQueue<>(10); // 生产者线程可以调用 put() 方法，如果队列满则阻塞 // 消费者线程可以调用 take() 方法，如果队列空则阻塞 } }