LinkedBlockingQueue概述

LinkedBlockingDeque是由链表组成的可选双端阻塞队列，支持O(1)的时间复杂度从两端插入和移除元素。如果没有指定边界，它是整数。MAX_VALUE。

同步由ReentrantLock保证，等待通知通过使用条件实现。

类别结构和重要字段

公共类LinkedBlockingDeque & ltE & gt扩展AbstractQueue & ltE & gt实现阻塞请求& ltE & gt，Java . io . serializable { private static final long serialVersionUID =-387911632671998426 l；/* *双向链表节点*/静态最终类节点<>linkFirst

在尝试将节点添加到first之前，先进行更新，如果插入后超出了容量，则返回false。

private boolean linkFirst(Node<E> node) { // assert lock.isHeldByCurrentThread(); if (count >= capacity) return false; Node<E> f = first; node.next = f; first = node; if (last == null) last = node; else f.prev = node; ++count; notEmpty.signal(); return true; }

linkLast

在最后一个节点后添加节点node以更新最后一个节点。如果插入后超出了容量，则返回false。

private boolean linkLast(Node<E> node) { // assert lock.isHeldByCurrentThread(); if (count >= capacity) return false; Node<E> l = last; node.prev = l; last = node; if (first == null) first = node; else l.next = node; ++count; notEmpty.signal();// 满足notEmpty条件 return true; }

unlinkFirst

移除第一个节点并返回其项目值，如果队列为空，则返回full。

private E unlinkFirst() { // assert lock.isHeldByCurrentThread(); Node<E> f = first; if (f == null) return null; Node<E> n = f.next; E item = f.item; f.item = null; f.next = f; // help GC first = n; if (n == null) last = null; else n.prev = null; --count; notFull.signal();// 满足notFull条件 return item; }

unlinkLast

移除最后一个节点并返回其项目值，如果队列为空，则返回full。

private E unlinkLast() { // assert lock.isHeldByCurrentThread(); Node<E> l = last; if (l == null) return null; Node<E> p = l.prev; E item = l.item; l.item = null; l.prev = l; // help GC last = p; if (p == null) first = null; else p.next = null; --count; notFull.signal(); // 满足notFull条件 return item; }

取消链接

移除任何节点。注意，这里没有操作X本身的连接，因为它可能仍然被迭代器使用。

void unlink(Node<E> x) { // assert lock.isHeldByCurrentThread(); Node<E> p = x.prev; Node<E> n = x.next; // 移除的是first if (p == null) { unlinkFirst(); // 移除的是last } else if (n == null) { unlinkLast(); } else { // 移除的是中间节点 p.next = n; n.prev = p; x.item = null; // Don't mess with x's links. They ***y still be in use by // an iterator. // 这里x的prev和next指针都没有改变，因为他们可能在被iterator使用 --count; notFull.signal(); } }

摘要

LinkedBlockingDeque是由链表组成的可选双端阻塞队列，支持O(1)的时间复杂度从两端插入和移除元素。如果没有指定边界，它是整数。MAX_VALUE。

同步由ReentrantLock保证，等待通知通过使用条件实现。

上面描述的所有操作基本都是核心方法，比如putFirst、putLast、takeFirst、takeLast等方法都会调用上面的核心方法，实现上面的就比较简单了，也就是双端链表的基本操作。如果不明白，可以画图帮助理解。

本文来自MR.特别人士投稿，不代表舒华文档立场，如若转载，请注明出处：https://www.chinashuhua.cn/24/475918.html