当前位置：首页 > news >正文

java列队多种实现方式，

news 2025/9/23 11:38:58

在Java中，队列（Queue）是一种常用的数据结构，遵循FIFO（先进先出）原则。Java提供了多种队列实现方式，适用于不同的场景。以下是几种常见的队列实现方式：

LinkedList实现
LinkedList实现了Queue接口，可以作为队列使用，它是一个双向链表结构。

import java.util.LinkedList;
import java.util.Queue;public class LinkedListQueueExample {public static void main(String[] args) {Queue<String> queue = new LinkedList<>();// 添加元素queue.add("元素1");queue.offer("元素2");// 获取队头元素（不删除）System.out.println("队头元素: " + queue.peek());// 获取并删除队头元素while (!queue.isEmpty()) {System.out.println("出队元素: " + queue.poll());}}
}

ArrayDeque实现
ArrayDeque是基于数组的双端队列，既可以作为队列使用，也可以作为栈使用，性能通常比LinkedList更好。

import java.util.ArrayDeque;
import java.util.Queue;public class ArrayDequeQueueExample {public static void main(String[] args) {Queue<Integer> queue = new ArrayDeque<>();// 添加元素for (int i = 1; i <= 5; i++) {queue.offer(i);}// 遍历队列System.out.println("队列元素: " + queue);// 出队操作while (!queue.isEmpty()) {System.out.println("出队: " + queue.poll());}}
}

PriorityQueue实现
PriorityQueue是一个优先级队列，它不是按照元素的插入顺序，而是按照元素的优先级进行排序。

import java.util.PriorityQueue;
import java.util.Queue;public class PriorityQueueExample {public static void main(String[] args) {// 自然排序（从小到大）Queue<Integer> priorityQueue = new PriorityQueue<>();// 添加元素priorityQueue.offer(3);priorityQueue.offer(1);priorityQueue.offer(5);priorityQueue.offer(2);// 出队（按优先级顺序）while (!priorityQueue.isEmpty()) {System.out.println("出队: " + priorityQueue.poll());}}
}

ConcurrentLinkedQueue实现
ConcurrentLinkedQueue是一个线程安全的无界队列，适用于多线程环境。

import java.util.Queue;
import java.util.concurrent.ConcurrentLinkedQueue;public class ConcurrentQueueExample {public static void main(String[] args) throws InterruptedException {Queue<String> concurrentQueue = new ConcurrentLinkedQueue<>();// 线程1：添加元素Thread producer = new Thread(() -> {for (int i = 1; i <= 5; i++) {concurrentQueue.offer("元素" + i);try {Thread.sleep(100);} catch (InterruptedException e) {e.printStackTrace();}}});// 线程2：取出元素Thread consumer = new Thread(() -> {while (true) {String element = concurrentQueue.poll();if (element != null) {System.out.println("消费: " + element);}if (element != null && element.equals("元素5")) {break;}try {Thread.sleep(150);} catch (InterruptedException e) {e.printStackTrace();}}});producer.start();consumer.start();producer.join();consumer.join();}
}