第55章 Java Queue接口

Queue接口概述

Queue接口是Java集合框架中的重要组成部分，它继承自Collection接口，代表一个队列数据结构。队列遵循先进先出(FIFO - First In First Out)的原则，新元素从队尾加入，从队头移除。

                 Queue接口的核心特点
                FIFO原则：先进先出的数据访问模式
双端操作：支持在队头和队尾进行操作
多种实现：LinkedList、ArrayDeque、PriorityQueue等
线程安全选项：提供并发安全的实现类

            

Queue接口的主要方法

方法	描述	异常处理
`offer(E e)`	向队尾添加元素	返回false而不抛异常
`poll()`	移除并返回队头元素	队列为空时返回null
`peek()`	查看队头元素但不移除	队列为空时返回null
`add(E e)`	向队尾添加元素	失败时抛出异常
`remove()`	移除并返回队头元素	队列为空时抛出异常
`element()`	查看队头元素但不移除	队列为空时抛出异常

Queue基础操作示例

让我们通过一个完整的示例来学习Queue接口的基本使用方法：

QueueBasicExample.java

import java.util.*;

/**
 * Queue接口基础示例
 * 
 * 演示Queue接口的基本操作和常用方法
 * Queue是一个先进先出(FIFO)的数据结构
 */
public class QueueBasicExample {
    
    public static void main(String[] args) {
        System.out.println("=== Queue接口基础示例 ===");
        
        // 创建LinkedList实现的Queue
        Queue queue = new LinkedList<>();
        
        // 演示基本操作
        demonstrateBasicOperations(queue);
        
        System.out.println("\n=== ArrayDeque实现的Queue ===");
        
        // 创建ArrayDeque实现的Queue
        Queue numberQueue = new ArrayDeque<>();
        demonstrateNumberQueue(numberQueue);
        
        System.out.println("\n=== PriorityQueue优先队列 ===");
        
        // 演示优先队列
        demonstratePriorityQueue();
    }
    
    /**
     * 演示Queue的基本操作
     */
    private static void demonstrateBasicOperations(Queue queue) {
        System.out.println("\n--- 基本操作演示 ---");
        
        // 添加元素 - offer()方法
        queue.offer("第一个元素");
        queue.offer("第二个元素");
        queue.offer("第三个元素");
        
        System.out.println("添加元素后的队列: " + queue);
        System.out.println("队列大小: " + queue.size());
        
        // 查看队头元素 - peek()方法
        String head = queue.peek();
        System.out.println("队头元素(peek): " + head);
        System.out.println("peek后队列: " + queue);
        
        // 移除并返回队头元素 - poll()方法
        String removed = queue.poll();
        System.out.println("移除的元素(poll): " + removed);
        System.out.println("poll后队列: " + queue);
        
        // 检查队列是否为空
        System.out.println("队列是否为空: " + queue.isEmpty());
    }
}

💻 查看完整代码 - 在线IDE体验

Queue实现类详解

Java提供了多种Queue接口的实现类，每种实现都有其特定的特点和适用场景：

LinkedList

特点：基于双向链表实现，支持null元素

优势：插入删除效率高，内存动态分配

适用：频繁插入删除操作的场景

ArrayDeque

特点：基于动态数组实现，不支持null元素

优势：性能优于LinkedList，内存连续

适用：一般队列操作的首选实现

PriorityQueue

特点：基于堆实现的优先队列

优势：自动按优先级排序

适用：需要优先级处理的场景

选择建议

一般用途：推荐使用ArrayDeque，性能最佳
需要null元素：使用LinkedList
优先级处理：使用PriorityQueue
线程安全：使用ArrayBlockingQueue或LinkedBlockingQueue

Queue实际应用场景

Queue在实际开发中有着广泛的应用，以下是一些典型的使用场景：

1. 任务调度系统

使用PriorityQueue实现基于优先级的任务调度：

任务调度示例

// 任务调度器
class TaskScheduler {
    private PriorityQueue taskQueue;
    
    public TaskScheduler() {
        // 按优先级排序，数字越小优先级越高
        this.taskQueue = new PriorityQueue<>(Comparator.comparingInt(Task::getPriority));
    }
    
    public void addTask(Task task) {
        taskQueue.offer(task);
        System.out.println("添加任务: " + task);
    }
    
    public void executeTasks() {
        System.out.println("开始执行任务:");
        while (!taskQueue.isEmpty()) {
            Task task = taskQueue.poll();
            System.out.println("执行任务: " + task);
        }
    }
}

2. 广度优先搜索(BFS)

Queue是实现BFS算法的核心数据结构：

BFS搜索示例

public List bfs(Map> graph, String start, String target) {
    Queue queue = new LinkedList<>();
    Set visited = new HashSet<>();
    Map parent = new HashMap<>();
    
    queue.offer(start);
    visited.add(start);
    parent.put(start, null);
    
    while (!queue.isEmpty()) {
        String current = queue.poll();
        
        if (current.equals(target)) {
            return buildPath(parent, start, target);
        }
        
        for (String neighbor : graph.getOrDefault(current, new ArrayList<>())) {
            if (!visited.contains(neighbor)) {
                queue.offer(neighbor);
                visited.add(neighbor);
                parent.put(neighbor, current);
            }
        }
    }
    
    return new ArrayList<>(); // 未找到路径
}

3. 缓冲区管理

使用Queue实现循环缓冲区：

循环缓冲区示例

class CircularBuffer {
    private Queue buffer;
    private int maxSize;
    
    public CircularBuffer(int maxSize) {
        this.maxSize = maxSize;
        this.buffer = new LinkedList<>();
    }
    
    public void add(T item) {
        if (buffer.size() >= maxSize) {
            buffer.poll(); // 移除最旧的元素
        }
        buffer.offer(item);
    }
    
    public void display() {
        System.out.println("缓冲区内容: " + buffer);
    }
}

Queue使用最佳实践

                 推荐做法
                优先使用offer/poll/peek：这些方法提供更好的错误处理
选择合适的实现类：根据具体需求选择最适合的实现
考虑线程安全：多线程环境下使用并发安全的实现
合理设置容量：对于有界队列，设置合适的容量限制

            

注意事项

null元素：ArrayDeque不支持null元素
性能考虑：LinkedList在某些场景下性能较差
内存使用：PriorityQueue的内部排序会消耗额外资源
并发访问：普通Queue实现不是线程安全的

章节总结

通过本章的学习，我们深入了解了Java Queue接口的特性和应用：

                 核心要点
                FIFO原则：Queue遵循先进先出的数据访问模式
方法分类：提供异常和非异常两套操作方法
多种实现：LinkedList、ArrayDeque、PriorityQueue各有特色
实际应用：任务调度、BFS搜索、缓冲区管理等场景
性能考虑：ArrayDeque通常是最佳选择

            

Queue接口是Java集合框架中的重要组成部分，掌握其特性和使用方法对于编写高效的Java程序至关重要。在实际开发中，根据具体需求选择合适的实现类，并遵循最佳实践，可以显著提升程序的性能和可维护性。

学习时间

难度等级

代码示例

核心概念