1. Android开发中的队列数据结构基础在移动应用开发领域数据结构的选择直接影响着应用性能和用户体验。作为Android开发者我们经常需要处理各种数据流动场景比如网络请求排队、事件处理、消息传递等。队列(Queue)和双端队列(Deque)正是解决这类问题的利器。队列遵循FIFO(先进先出)原则就像餐厅排队取餐的队伍先来的顾客先获得服务。而双端队列则更为灵活允许从两端进行操作相当于一个可以两头排队取餐的特殊餐厅。在Android系统中这种数据结构被广泛应用于Handler消息机制、线程池任务调度等核心组件。注意虽然Java集合框架提供了多种队列实现但在Android开发中需要特别注意内存占用和线程安全问题这对移动设备的有限资源尤为重要。2. Queue在Android中的核心实现与应用2.1 Java集合框架中的Queue实现Android基于Java集合框架提供了多种队列实现每种都有其特定用途LinkedList最基础的队列实现同时实现了List和Deque接口。适合小规模数据且需要频繁插入删除的场景。QueueString queue new LinkedList(); queue.offer(任务1); // 入队 String task queue.poll(); // 出队PriorityQueue优先级队列元素按自然顺序或Comparator指定的顺序出队。常用于任务调度PriorityQueueTask priorityQueue new PriorityQueue(Comparator.comparingInt(Task::getPriority)); priorityQueue.offer(new Task(紧急任务, 1)); priorityQueue.offer(new Task(普通任务, 3)); Task nextTask priorityQueue.poll(); // 总是获取优先级最高的任务ArrayBlockingQueue线程安全的阻塞队列固定大小。在Android中常用于生产者-消费者模式BlockingQueueBitmap imageQueue new ArrayBlockingQueue(10); // 生产者线程 new Thread(() - { try { imageQueue.put(bitmap); // 队列满时会阻塞 } catch (InterruptedException e) { Thread.currentThread().interrupt(); } }).start(); // 消费者线程 new Thread(() - { try { Bitmap img imageQueue.take(); // 队列空时会阻塞 processImage(img); } catch (InterruptedException e) { Thread.currentThread().interrupt(); } }).start();2.2 Android特有队列应用场景Handler消息队列Android的UI线程消息机制核心就是基于队列实现的Handler handler new Handler(Looper.getMainLooper()) { Override public void handleMessage(Message msg) { // 处理消息 } }; // 发送消息到队列 handler.sendMessage(handler.obtainMessage(WHAT, obj));IntentService的任务队列虽然IntentService已废弃但其队列处理机制值得学习// 内部使用LinkedBlockingQueue处理传入的Intent Override protected void onHandleIntent(Nullable Intent intent) { // 顺序处理每个请求 }Glide图片加载队列图片加载库内部使用优先级队列管理加载请求Glide.with(context) .load(url) .priority(Priority.HIGH) // 设置加载优先级 .into(imageView);3. Deque双端队列的进阶应用3.1 Deque的核心特性双端队列(Deque)扩展了Queue接口允许在两端进行插入和删除操作。Android开发中常用的实现是ArrayDeque和LinkedList操作Queue方法Deque等效方法插入头部无addFirst/offerFirst插入尾部add/offeraddLast/offerLast移除头部remove/pollremoveFirst/pollFirst移除尾部无removeLast/pollLast查看头部element/peekgetFirst/peekFirst查看尾部无getLast/peekLast3.2 Android中的典型应用场景浏览历史记录实现可以前进后退的浏览记录DequeString history new ArrayDeque(); history.push(页面1); // 相当于addFirst history.push(页面2); String current history.pop(); // 相当于removeFirst // 实现后退功能 if (!history.isEmpty()) { String previousPage history.pop(); loadPage(previousPage); }撤销/重做功能常见于绘图或编辑类应用DequeAction undoStack new ArrayDeque(); DequeAction redoStack new ArrayDeque(); public void executeAction(Action action) { action.execute(); undoStack.push(action); redoStack.clear(); // 新操作清空重做栈 } public void undo() { if (!undoStack.isEmpty()) { Action action undoStack.pop(); action.undo(); redoStack.push(action); } }滑动窗口算法解决某些特定性能问题// 求滑动窗口最大值 public int[] maxSlidingWindow(int[] nums, int k) { if (nums null || k 0) return new int[0]; int[] result new int[nums.length - k 1]; DequeInteger deque new ArrayDeque(); for (int i 0; i nums.length; i) { // 移除超出窗口范围的索引 while (!deque.isEmpty() deque.peekFirst() i - k 1) { deque.pollFirst(); } // 移除小于当前值的元素保持队列递减 while (!deque.isEmpty() nums[deque.peekLast()] nums[i]) { deque.pollLast(); } deque.offerLast(i); if (i k - 1) { result[i - k 1] nums[deque.peekFirst()]; } } return result; }4. 性能优化与线程安全实践4.1 各队列实现的性能对比在选择队列实现时了解其时间复杂度至关重要操作LinkedListArrayDequePriorityQueueArrayBlockingQueue插入(add)O(1)O(1)O(log n)O(1)移除(remove)O(1)O(1)O(log n)O(1)查看(peek)O(1)O(1)O(1)O(1)线程安全否否否是内存占用较高较低中等固定提示对于大多数Android应用场景ArrayDeque是性能最好的选择除非需要特定功能如阻塞或优先级。4.2 多线程环境下的队列选择Android开发中常见的线程安全队列解决方案BlockingQueue系列ArrayBlockingQueue固定大小的数组实现LinkedBlockingQueue可选边界默认Integer.MAX_VALUEPriorityBlockingQueue带优先级的无界队列SynchronousQueue不存储元素的特殊队列ConcurrentLinkedQueue非阻塞的高性能队列适合高并发场景ConcurrentLinkedQueueEvent eventQueue new ConcurrentLinkedQueue(); // 生产者 new Thread(() - { eventQueue.offer(new Event(...)); }).start(); // 消费者 new Thread(() - { Event event eventQueue.poll(); if (event ! null) { processEvent(event); } }).start();使用Collections工具类包装QueueData safeQueue Collections.synchronizedCollection(new LinkedList()); // 需要手动同步遍历操作 synchronized (safeQueue) { for (Data item : safeQueue) { processItem(item); } }4.3 内存优化技巧避免队列膨胀设置合理的队列边界使用DiscardPolicy处理溢出定期清理无用元素对象池技术// 使用队列实现简单的对象池 public class BitmapPool { private final QueueBitmap pool new ArrayDeque(10); public Bitmap getBitmap(int width, int height) { Bitmap bitmap pool.poll(); if (bitmap null || bitmap.isRecycled()) { return Bitmap.createBitmap(width, height, Bitmap.Config.ARGB_8888); } return bitmap; } public void recycle(Bitmap bitmap) { if (bitmap ! null !bitmap.isRecycled()) { bitmap.eraseColor(Color.TRANSPARENT); pool.offer(bitmap); } } }使用SparseArray替代HashMap当键为整数时可以节省内存SparseArrayQueueMessage messageQueues new SparseArray(); messageQueues.put(userId, new ArrayDeque()); QueueMessage queue messageQueues.get(userId);5. 常见问题排查与调试技巧5.1 队列操作异常排查NoSuchElementException原因在空队列上调用remove()或element()解决改用poll()和peek()方法或先检查isEmpty()NullPointerException原因大多数队列实现不允许插入null元素解决插入前检查null或用特殊对象替代nullIllegalStateException原因固定大小队列已满时调用add()解决使用offer()方法替代它会返回false而不是抛出异常5.2 多线程问题诊断死锁检测使用Android Studio的CPU Profiler分析线程状态查找阻塞在take()或put()操作的线程数据不一致检查是否在非线程安全队列上进行了并发操作考虑使用ConcurrentLinkedQueue或同步包装器内存泄漏排查使用Memory Profiler检查队列持有的对象特别注意静态队列和长生命周期队列5.3 性能问题优化队列成为性能瓶颈检查是否有多生产者单消费者导致的竞争考虑使用多个队列或工作窃取算法GC频繁触发对象在队列中频繁创建和销毁实现对象池减少垃圾产生ANR问题主线程执行了阻塞队列操作确保在主线程只使用非阻塞方法或Handler// 错误示例 - 可能导致ANR public void onUserAction() { Bitmap bitmap imageBlockingQueue.take(); // 在主线程阻塞 imageView.setImageBitmap(bitmap); } // 正确做法 - 使用回调或Handler public void onUserAction() { new Thread(() - { final Bitmap bitmap imageBlockingQueue.take(); runOnUiThread(() - imageView.setImageBitmap(bitmap)); }).start(); }6. Kotlin中的队列实践6.1 Kotlin扩展函数增强队列APIKotlin为Java集合提供了许多便利的扩展函数val queue: QueueString LinkedList() // 安全操作 val first queue.peek() ?: return val item queue.poll() ?: defaultItem // 使用let简化操作 queue.poll()?.let { processItem(it) } // 使用also记录日志 queue.offer(item).also { if (it) Log.d(Queue, Item added) }6.2 协程与队列的结合Kotlin协程提供了更优雅的异步队列处理方式val channel ChannelData(capacity Channel.UNLIMITED) // 生产者协程 launch { while (true) { val data produceData() channel.send(data) } } // 消费者协程 launch { for (data in channel) { processData(data) } }6.3 不可变队列与函数式编程Kotlin鼓励不可变集合可以使用persistent数据结构import kotlinx.collections.immutable.persistentListOf var immutableQueue persistentListOfString() immutableQueue immutableQueue.add(item1) // 返回新队列 val firstItem immutableQueue.first()7. 高级应用自定义队列实现7.1 实现优先级延迟队列结合PriorityQueue和Delayed接口实现延迟任务队列public class DelayedTask implements Delayed { private final Runnable task; private final long triggerTime; public DelayedTask(Runnable task, long delayMillis) { this.task task; this.triggerTime System.currentTimeMillis() delayMillis; } Override public long getDelay(TimeUnit unit) { return unit.convert(triggerTime - System.currentTimeMillis(), TimeUnit.MILLISECONDS); } Override public int compareTo(Delayed other) { return Long.compare(triggerTime, ((DelayedTask)other).triggerTime); } public void execute() { task.run(); } } // 使用示例 DelayQueueDelayedTask delayQueue new DelayQueue(); delayQueue.put(new DelayedTask(() - showNotification(), 5000)); // 5秒后执行 // 处理线程 new Thread(() - { while (!Thread.interrupted()) { try { DelayedTask task delayQueue.take(); task.execute(); } catch (InterruptedException e) { Thread.currentThread().interrupt(); } } }).start();7.2 实现工作窃取队列仿照ForkJoinPool的工作窃取算法实现高效并行处理public class WorkStealingQueueT { private final DequeT[] queues; private final int nThreads; SuppressWarnings(unchecked) public WorkStealingQueue(int nThreads) { this.nThreads nThreads; this.queues new ArrayDeque[nThreads]; for (int i 0; i nThreads; i) { queues[i] new ArrayDeque(); } } public void push(T task, int threadId) { queues[threadId].push(task); } public T pop(int threadId) { return queues[threadId].poll(); } public T steal(int victimThreadId) { return queues[victimThreadId].pollLast(); } } // 使用示例 WorkStealingQueueRunnable wsQueue new WorkStealingQueue(4); ExecutorService executor Executors.newFixedThreadPool(4); for (int i 0; i 4; i) { final int threadId i; executor.submit(() - { while (!Thread.interrupted()) { Runnable task wsQueue.pop(threadId); if (task null) { // 本地队列为空尝试窃取 for (int j 0; j 4; j) { if (j ! threadId) { task wsQueue.steal(j); if (task ! null) break; } } } if (task ! null) { task.run(); } else { Thread.yield(); } } }); }7.3 实现无锁队列使用AtomicReference实现高性能无锁队列public class LockFreeQueueT { private static class NodeT { final T item; volatile NodeT next; Node(T item) { this.item item; } } private final AtomicReferenceNodeT head new AtomicReference(); private final AtomicReferenceNodeT tail new AtomicReference(); public LockFreeQueue() { NodeT dummy new Node(null); head.set(dummy); tail.set(dummy); } public void enqueue(T item) { NodeT newNode new Node(item); while (true) { NodeT currentTail tail.get(); NodeT tailNext currentTail.next; if (currentTail tail.get()) { if (tailNext ! null) { // 有其他线程正在添加元素帮助推进tail tail.compareAndSet(currentTail, tailNext); } else { if (currentTail.next.compareAndSet(null, newNode)) { // 成功添加新节点推进tail tail.compareAndSet(currentTail, newNode); return; } } } } } public T dequeue() { while (true) { NodeT currentHead head.get(); NodeT currentTail tail.get(); NodeT headNext currentHead.next; if (currentHead head.get()) { if (currentHead currentTail) { if (headNext null) { return null; // 队列为空 } // tail落后了帮助推进 tail.compareAndSet(currentTail, headNext); } else { T item headNext.item; if (head.compareAndSet(currentHead, headNext)) { return item; } } } } } } 
长河君 · 2026/8/7 14:27:04 · 阅读 1.2k Android开发中的队列与双端队列应用实践
1. Android开发中的队列数据结构基础在移动应用开发领域数据结构的选择直接影响着应用性能和用户体验。作为Android开发者我们经常需要处理各种数据流动场景比如网络请求排队、事件处理、消息传递等。队列(Queue)和双端队列(Deque)正是解决这类问题的利器。队列遵循FIFO(先进先出)原则就像餐厅排队取餐的队伍先来的顾客先获得服务。而双端队列则更为灵活允许从两端进行操作相当于一个可以两头排队取餐的特殊餐厅。在Android系统中这种数据结构被广泛应用于Handler消息机制、线程池任务调度等核心组件。注意虽然Java集合框架提供了多种队列实现但在Android开发中需要特别注意内存占用和线程安全问题这对移动设备的有限资源尤为重要。2. Queue在Android中的核心实现与应用2.1 Java集合框架中的Queue实现Android基于Java集合框架提供了多种队列实现每种都有其特定用途LinkedList最基础的队列实现同时实现了List和Deque接口。适合小规模数据且需要频繁插入删除的场景。QueueString queue new LinkedList(); queue.offer(任务1); // 入队 String task queue.poll(); // 出队PriorityQueue优先级队列元素按自然顺序或Comparator指定的顺序出队。常用于任务调度PriorityQueueTask priorityQueue new PriorityQueue(Comparator.comparingInt(Task::getPriority)); priorityQueue.offer(new Task(紧急任务, 1)); priorityQueue.offer(new Task(普通任务, 3)); Task nextTask priorityQueue.poll(); // 总是获取优先级最高的任务ArrayBlockingQueue线程安全的阻塞队列固定大小。在Android中常用于生产者-消费者模式BlockingQueueBitmap imageQueue new ArrayBlockingQueue(10); // 生产者线程 new Thread(() - { try { imageQueue.put(bitmap); // 队列满时会阻塞 } catch (InterruptedException e) { Thread.currentThread().interrupt(); } }).start(); // 消费者线程 new Thread(() - { try { Bitmap img imageQueue.take(); // 队列空时会阻塞 processImage(img); } catch (InterruptedException e) { Thread.currentThread().interrupt(); } }).start();2.2 Android特有队列应用场景Handler消息队列Android的UI线程消息机制核心就是基于队列实现的Handler handler new Handler(Looper.getMainLooper()) { Override public void handleMessage(Message msg) { // 处理消息 } }; // 发送消息到队列 handler.sendMessage(handler.obtainMessage(WHAT, obj));IntentService的任务队列虽然IntentService已废弃但其队列处理机制值得学习// 内部使用LinkedBlockingQueue处理传入的Intent Override protected void onHandleIntent(Nullable Intent intent) { // 顺序处理每个请求 }Glide图片加载队列图片加载库内部使用优先级队列管理加载请求Glide.with(context) .load(url) .priority(Priority.HIGH) // 设置加载优先级 .into(imageView);3. Deque双端队列的进阶应用3.1 Deque的核心特性双端队列(Deque)扩展了Queue接口允许在两端进行插入和删除操作。Android开发中常用的实现是ArrayDeque和LinkedList操作Queue方法Deque等效方法插入头部无addFirst/offerFirst插入尾部add/offeraddLast/offerLast移除头部remove/pollremoveFirst/pollFirst移除尾部无removeLast/pollLast查看头部element/peekgetFirst/peekFirst查看尾部无getLast/peekLast3.2 Android中的典型应用场景浏览历史记录实现可以前进后退的浏览记录DequeString history new ArrayDeque(); history.push(页面1); // 相当于addFirst history.push(页面2); String current history.pop(); // 相当于removeFirst // 实现后退功能 if (!history.isEmpty()) { String previousPage history.pop(); loadPage(previousPage); }撤销/重做功能常见于绘图或编辑类应用DequeAction undoStack new ArrayDeque(); DequeAction redoStack new ArrayDeque(); public void executeAction(Action action) { action.execute(); undoStack.push(action); redoStack.clear(); // 新操作清空重做栈 } public void undo() { if (!undoStack.isEmpty()) { Action action undoStack.pop(); action.undo(); redoStack.push(action); } }滑动窗口算法解决某些特定性能问题// 求滑动窗口最大值 public int[] maxSlidingWindow(int[] nums, int k) { if (nums null || k 0) return new int[0]; int[] result new int[nums.length - k 1]; DequeInteger deque new ArrayDeque(); for (int i 0; i nums.length; i) { // 移除超出窗口范围的索引 while (!deque.isEmpty() deque.peekFirst() i - k 1) { deque.pollFirst(); } // 移除小于当前值的元素保持队列递减 while (!deque.isEmpty() nums[deque.peekLast()] nums[i]) { deque.pollLast(); } deque.offerLast(i); if (i k - 1) { result[i - k 1] nums[deque.peekFirst()]; } } return result; }4. 性能优化与线程安全实践4.1 各队列实现的性能对比在选择队列实现时了解其时间复杂度至关重要操作LinkedListArrayDequePriorityQueueArrayBlockingQueue插入(add)O(1)O(1)O(log n)O(1)移除(remove)O(1)O(1)O(log n)O(1)查看(peek)O(1)O(1)O(1)O(1)线程安全否否否是内存占用较高较低中等固定提示对于大多数Android应用场景ArrayDeque是性能最好的选择除非需要特定功能如阻塞或优先级。4.2 多线程环境下的队列选择Android开发中常见的线程安全队列解决方案BlockingQueue系列ArrayBlockingQueue固定大小的数组实现LinkedBlockingQueue可选边界默认Integer.MAX_VALUEPriorityBlockingQueue带优先级的无界队列SynchronousQueue不存储元素的特殊队列ConcurrentLinkedQueue非阻塞的高性能队列适合高并发场景ConcurrentLinkedQueueEvent eventQueue new ConcurrentLinkedQueue(); // 生产者 new Thread(() - { eventQueue.offer(new Event(...)); }).start(); // 消费者 new Thread(() - { Event event eventQueue.poll(); if (event ! null) { processEvent(event); } }).start();使用Collections工具类包装QueueData safeQueue Collections.synchronizedCollection(new LinkedList()); // 需要手动同步遍历操作 synchronized (safeQueue) { for (Data item : safeQueue) { processItem(item); } }4.3 内存优化技巧避免队列膨胀设置合理的队列边界使用DiscardPolicy处理溢出定期清理无用元素对象池技术// 使用队列实现简单的对象池 public class BitmapPool { private final QueueBitmap pool new ArrayDeque(10); public Bitmap getBitmap(int width, int height) { Bitmap bitmap pool.poll(); if (bitmap null || bitmap.isRecycled()) { return Bitmap.createBitmap(width, height, Bitmap.Config.ARGB_8888); } return bitmap; } public void recycle(Bitmap bitmap) { if (bitmap ! null !bitmap.isRecycled()) { bitmap.eraseColor(Color.TRANSPARENT); pool.offer(bitmap); } } }使用SparseArray替代HashMap当键为整数时可以节省内存SparseArrayQueueMessage messageQueues new SparseArray(); messageQueues.put(userId, new ArrayDeque()); QueueMessage queue messageQueues.get(userId);5. 常见问题排查与调试技巧5.1 队列操作异常排查NoSuchElementException原因在空队列上调用remove()或element()解决改用poll()和peek()方法或先检查isEmpty()NullPointerException原因大多数队列实现不允许插入null元素解决插入前检查null或用特殊对象替代nullIllegalStateException原因固定大小队列已满时调用add()解决使用offer()方法替代它会返回false而不是抛出异常5.2 多线程问题诊断死锁检测使用Android Studio的CPU Profiler分析线程状态查找阻塞在take()或put()操作的线程数据不一致检查是否在非线程安全队列上进行了并发操作考虑使用ConcurrentLinkedQueue或同步包装器内存泄漏排查使用Memory Profiler检查队列持有的对象特别注意静态队列和长生命周期队列5.3 性能问题优化队列成为性能瓶颈检查是否有多生产者单消费者导致的竞争考虑使用多个队列或工作窃取算法GC频繁触发对象在队列中频繁创建和销毁实现对象池减少垃圾产生ANR问题主线程执行了阻塞队列操作确保在主线程只使用非阻塞方法或Handler// 错误示例 - 可能导致ANR public void onUserAction() { Bitmap bitmap imageBlockingQueue.take(); // 在主线程阻塞 imageView.setImageBitmap(bitmap); } // 正确做法 - 使用回调或Handler public void onUserAction() { new Thread(() - { final Bitmap bitmap imageBlockingQueue.take(); runOnUiThread(() - imageView.setImageBitmap(bitmap)); }).start(); }6. Kotlin中的队列实践6.1 Kotlin扩展函数增强队列APIKotlin为Java集合提供了许多便利的扩展函数val queue: QueueString LinkedList() // 安全操作 val first queue.peek() ?: return val item queue.poll() ?: defaultItem // 使用let简化操作 queue.poll()?.let { processItem(it) } // 使用also记录日志 queue.offer(item).also { if (it) Log.d(Queue, Item added) }6.2 协程与队列的结合Kotlin协程提供了更优雅的异步队列处理方式val channel ChannelData(capacity Channel.UNLIMITED) // 生产者协程 launch { while (true) { val data produceData() channel.send(data) } } // 消费者协程 launch { for (data in channel) { processData(data) } }6.3 不可变队列与函数式编程Kotlin鼓励不可变集合可以使用persistent数据结构import kotlinx.collections.immutable.persistentListOf var immutableQueue persistentListOfString() immutableQueue immutableQueue.add(item1) // 返回新队列 val firstItem immutableQueue.first()7. 高级应用自定义队列实现7.1 实现优先级延迟队列结合PriorityQueue和Delayed接口实现延迟任务队列public class DelayedTask implements Delayed { private final Runnable task; private final long triggerTime; public DelayedTask(Runnable task, long delayMillis) { this.task task; this.triggerTime System.currentTimeMillis() delayMillis; } Override public long getDelay(TimeUnit unit) { return unit.convert(triggerTime - System.currentTimeMillis(), TimeUnit.MILLISECONDS); } Override public int compareTo(Delayed other) { return Long.compare(triggerTime, ((DelayedTask)other).triggerTime); } public void execute() { task.run(); } } // 使用示例 DelayQueueDelayedTask delayQueue new DelayQueue(); delayQueue.put(new DelayedTask(() - showNotification(), 5000)); // 5秒后执行 // 处理线程 new Thread(() - { while (!Thread.interrupted()) { try { DelayedTask task delayQueue.take(); task.execute(); } catch (InterruptedException e) { Thread.currentThread().interrupt(); } } }).start();7.2 实现工作窃取队列仿照ForkJoinPool的工作窃取算法实现高效并行处理public class WorkStealingQueueT { private final DequeT[] queues; private final int nThreads; SuppressWarnings(unchecked) public WorkStealingQueue(int nThreads) { this.nThreads nThreads; this.queues new ArrayDeque[nThreads]; for (int i 0; i nThreads; i) { queues[i] new ArrayDeque(); } } public void push(T task, int threadId) { queues[threadId].push(task); } public T pop(int threadId) { return queues[threadId].poll(); } public T steal(int victimThreadId) { return queues[victimThreadId].pollLast(); } } // 使用示例 WorkStealingQueueRunnable wsQueue new WorkStealingQueue(4); ExecutorService executor Executors.newFixedThreadPool(4); for (int i 0; i 4; i) { final int threadId i; executor.submit(() - { while (!Thread.interrupted()) { Runnable task wsQueue.pop(threadId); if (task null) { // 本地队列为空尝试窃取 for (int j 0; j 4; j) { if (j ! threadId) { task wsQueue.steal(j); if (task ! null) break; } } } if (task ! null) { task.run(); } else { Thread.yield(); } } }); }7.3 实现无锁队列使用AtomicReference实现高性能无锁队列public class LockFreeQueueT { private static class NodeT { final T item; volatile NodeT next; Node(T item) { this.item item; } } private final AtomicReferenceNodeT head new AtomicReference(); private final AtomicReferenceNodeT tail new AtomicReference(); public LockFreeQueue() { NodeT dummy new Node(null); head.set(dummy); tail.set(dummy); } public void enqueue(T item) { NodeT newNode new Node(item); while (true) { NodeT currentTail tail.get(); NodeT tailNext currentTail.next; if (currentTail tail.get()) { if (tailNext ! null) { // 有其他线程正在添加元素帮助推进tail tail.compareAndSet(currentTail, tailNext); } else { if (currentTail.next.compareAndSet(null, newNode)) { // 成功添加新节点推进tail tail.compareAndSet(currentTail, newNode); return; } } } } } public T dequeue() { while (true) { NodeT currentHead head.get(); NodeT currentTail tail.get(); NodeT headNext currentHead.next; if (currentHead head.get()) { if (currentHead currentTail) { if (headNext null) { return null; // 队列为空 } // tail落后了帮助推进 tail.compareAndSet(currentTail, headNext); } else { T item headNext.item; if (head.compareAndSet(currentHead, headNext)) { return item; } } } } } }