热门标签 | HotTags
当前位置:  开发笔记 > 编程语言 > 正文

java源码解读queue

queue接口特点:可以模拟队列行为,即“先进先出”。接口结构queue接口继承了Collection接口,并增加了一些新方法12345678910111213141516publ

queue接口特点:可以模拟队列行为,即“先进先出”。

接口结构

queue接口继承了Collection接口,并增加了一些新方法

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
public interface <E> extends Collection<E>{


boolean add(E e);
//将元素插入队列,如果失败返回false
boolean offer(E e);
//移除并返回队列中的第一个元素,队列为空时,抛异常
E remove();
//移除并返回队列中的第一个元素,队列为空时,返回null
E poll();
//返回队列中第一个元素,但不移除,队列为空时,抛异常
E element();
//返回队列中第一个元素,但不移除,对列为空时,返回null
E peek();

}

抽象类AbstractQueue

queue接口中,add与offer、remove与poll、element与peek,功能一致,只是对异常情况的处理不同。AbstractQueue源码中可以看出这些方法处理异常的方式。

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
public abstract class AbstractQueue<E>
extends AbstractCollection<E>
implements <E> {

protected AbstractQueue() {
}

//add底层调用offer,当offer失败返回false时,add方法抛出异常
public boolean add(E e) {
if (offer(e))
return true;
else
throw new IllegalStateException("Queue full");
}
//remove底层调用poll,当poll返回null时,remove方法抛出异常
public E remove() {
E x = poll();
if (x != null)
return x;
else
throw new NoSuchElementException();
}
//element底层调用peek,当peek返回null时,element方法抛出异常
public E element() {
E x = peek();
if (x != null)
return x;
else
throw new NoSuchElementException();
}
//clear方法循环调用poll,直到返回为null
public void clear() {
while (poll() != null)
;
}

public boolean addAll(Collectionextends E> c) {
if (c == null)
throw new NullPointerException();
if (c == this)
throw new IllegalArgumentException();
boolean modified = false;
for (E e : c)
if (add(e))
modified = true;
return modified;
}

}

Deque接口

Deque是双端队列,底层由循环数组实现,其继承了Queue接口,并扩展了新特性。
Deque重写了Queue的全部方法,Stack、Collection的部分方法,并增加了对首尾元素处理的相关方法。

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
public interface Deque<E> extends <E> {

void addFirst(E e);

void addLast(E e);

boolean offerFirst(E e);

boolean offerLast(E e);

E removeFirst();

E removeLast();

E pollFirst();

E pollLast();

E getFirst();

E getLast();

E peekFirst();

E peekLast();

boolean removeFirstOccurrence(Object o);

boolean removeLastOccurrence(Object o);

// *** Queue methods ***

boolean add(E e);

boolean offer(E e);

E remove();

E poll();

E element();

E peek();


// *** Stack methods ***

void push(E e);

E pop();


// *** Collection methods ***

boolean remove(Object o);

boolean contains(Object o);

public int size();

Iterator iterator();

Iterator descendingIterator();

}

ArrayDeque

ArrayDeque不可以存取null元素,因为会根据某个位置是否为null来判断元素是否存在。
当作为栈使用时,性能比stack好,作为队列使用时,性能比linkedlist好

类定义

继承了AbstractCollection,实现了Deque接口

1
2
public class ArrayDeque extends AbstractCollection
implements Deque, Cloneable, Serializable

重要的成员变量

1
2
3
4
// 第一个元素的索引  
private transient int head;
// 下个要添加元素的位置,为末尾元素的索引 + 1
private transient int tail;

构造方法

1
2
3
4
5
6
7
8
9
10
11
12
13
14
//默认数组大小16
public ArrayDeque() {
elements = new Object[16];
}
//传入数组大小
public ArrayDeque(int numElements) {
//调整实际数组大小为大于传入值的最小的2的幂次
allocateElements(numElements);
}
//直接传入集合
public ArrayDeque(Collectionextends E> c) {
allocateElements(c.size());
addAll(c);
}

调整数组大小

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
private void allocateElements(int numElements) {  
int initialCapacity = MIN_INITIAL_CAPACITY;
// 找到大于需要长度的最小的2的幂整数。
if (numElements >= initialCapacity) {
initialCapacity = numElements;
initialCapacity |= (initialCapacity >>> 1);
initialCapacity |= (initialCapacity >>> 2);
initialCapacity |= (initialCapacity >>> 4);
initialCapacity |= (initialCapacity >>> 8);
initialCapacity |= (initialCapacity >>> 16);
initialCapacity++;

if (initialCapacity <0) // Too many elements, must back off
initialCapacity >>>= 1;// Good luck allocating 2 ^ 30 elements
}
elements = (E[]) new Object[initialCapacity];
}

add

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
   public void addFirst(E e) {
if (e == null)
throw new NullPointerException();
//因为elements.length是2的幂次,(head - 1) & (elements.length - 1)相当于求模操作
//head-1只可能为-1,-1&(elements.length - 1)=(elements.length - 1)
elements[head = (head - 1) & (elements.length - 1)] = e;
if (head == tail)
doubleCapacity();
}


public void addLast(E e) {
if (e == null)
throw new NullPointerException();
elements[tail] = e;
//与head操作类似,为了处理tail=length-1的情况
if ( (tail = (tail + 1) & (elements.length - 1)) == head)
doubleCapacity();
}

public boolean add(E e) {
addLast(e);
return true;
}

public boolean offerFirst(E e) {
addFirst(e);
return true;
}

public boolean offerLast(E e) {
addLast(e);
return true;
}

remove

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
   public E removeFirst() {
E x = pollFirst();
if (x == null)
throw new NoSuchElementException();
return x;
}

public E removeLast() {
E x = pollLast();
if (x == null)
throw new NoSuchElementException();
return x;
}

public E pollFirst() {
int h = head;
("unchecked")
E result = (E) elements[h];
// Element is null if deque empty
if (result == null)
return null;
//删除头元素
elements[h] = null; // Must null out slot
//更改head下标,处理越界情况让head=0
head = (h + 1) & (elements.length - 1);
return result;
}

public E pollLast() {
//获取tail下标,处理tail=0的特殊情况,移除元素后tail=elements.length-1
int t = (tail - 1) & (elements.length - 1);
("unchecked")
E result = (E) elements[t];
if (result == null)
return null;
elements[t] = null;
//tail指向下个要添加元素的索引
tail = t;
return result;
}

删除指定元素

需要遍历数组,时间复杂度较高

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
   public boolean removeFirstOccurrence(Object o) {
if (o == null)
return false;
int mask = elements.length - 1;
int i = head;
Object x;
while ( (x = elements[i]) != null) {
if (o.equals(x)) {
delete(i);
return true;
}
i = (i + 1) & mask;
}
return false;
}

public boolean removeLastOccurrence(Object o) {
if (o == null)
return false;
int mask = elements.length - 1;
//末尾元素的索引
int i = (tail - 1) & mask;
Object x;
while ( (x = elements[i]) != null) {
if (o.equals(x)) {
delete(i);
return true;
}
//从尾到头遍历
i = (i - 1) & mask;
}
return false;
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
   private boolean delete(int i) {
//检查有效性
checkInvariants();
final Object[] elements = this.elements;
final int mask = elements.length - 1;
final int h = head;
final int t = tail;
//i前面的元素
final int frOnt= (i - h) & mask;
//i后面的元素
final int back = (t - i) & mask;

//i不在t和h之间
if (front >= ((t - h) & mask))
throw new ConcurrentModificationException();

// Optimize for least element motion
if (front
// head X X i X X X X tail,head-i的元素大于i-tail元素个数
if (h <= i) {
System.arraycopy(elements, h, elements, h + 1, front);
} else { // Wrap around
// i X X X X tail X X head
System.arraycopy(elements, 0, elements, 1, i);
elements[0] = elements[mask];
System.arraycopy(elements, h, elements, h + 1, mask - h);
}
elements[h] = null;
head = (h + 1) & mask;
return false;
} else {
// head X X X X i X X tail
if (i // Copy the null tail as well

System.arraycopy(elements, i + 1, elements, i, back);
tail = t - 1;
} else { // Wrap around
// tail X X head X X X X i
System.arraycopy(elements, i + 1, elements, i, mask - i);
elements[mask] = elements[0];
System.arraycopy(elements, 1, elements, 0, t);
tail = (t - 1) & mask;
}
return true;
}
1
2
3
4
5
6
7
8
9
10
   private void checkInvariants() {
//tail没有元素
assert elements[tail] == null;
//head和tail位置重合,队列为空,否则head、tail-1位置有元素
assert head == tail ? elements[head] == null :
(elements[head] != null &&
elements[(tail - 1) & (elements.length - 1)] != null);
//head-1的位置没有元素。
assert elements[(head - 1) & (elements.length - 1)] == null;
}

扩容

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
   private void doubleCapacity() {
//tail和head重合的时候进行扩容,此时tail在head左侧
assert head == tail;
int p = head;
int n = elements.length;
int r = n - p; // number of elements to the right of p
int newCapacity = n <<1;
if (newCapacity <0)
throw new IllegalStateException("Sorry, deque too big");
Object[] a = new Object[newCapacity];
//先复制head到element数组末尾的元素
System.arraycopy(elements, p, a, 0, r);
//在复制0到tail之间的元素
System.arraycopy(elements, 0, a, r, p);
elements = a;
head = 0;
tail = n;
}

原文:大专栏  java源码解读--queue


java源码解读--queue


推荐阅读
  • 本问题探讨了在特定条件下排列儿童队伍的方法数量。题目要求计算满足条件的队伍排列总数,并使用递推算法和大数处理技术来解决这一问题。 ... [详细]
  • 本题探讨如何通过最大流算法解决农场排水系统的设计问题。题目要求计算从水源点到汇合点的最大水流速率,使用经典的EK(Edmonds-Karp)和Dinic算法进行求解。 ... [详细]
  • 本文介绍如何使用阿里云的fastjson库解析包含时间戳、IP地址和参数等信息的JSON格式文本,并进行数据处理和保存。 ... [详细]
  • 微软Exchange服务器遭遇2022年版“千年虫”漏洞
    微软Exchange服务器在新年伊始遭遇了一个类似于‘千年虫’的日期处理漏洞,导致邮件传输受阻。该问题主要影响配置了FIP-FS恶意软件引擎的Exchange 2016和2019版本。 ... [详细]
  • QUIC协议:快速UDP互联网连接
    QUIC(Quick UDP Internet Connections)是谷歌开发的一种旨在提高网络性能和安全性的传输层协议。它基于UDP,并结合了TLS级别的安全性,提供了更高效、更可靠的互联网通信方式。 ... [详细]
  • 深入理解OAuth认证机制
    本文介绍了OAuth认证协议的核心概念及其工作原理。OAuth是一种开放标准,旨在为第三方应用提供安全的用户资源访问授权,同时确保用户的账户信息(如用户名和密码)不会暴露给第三方。 ... [详细]
  • 优化ListView性能
    本文深入探讨了如何通过多种技术手段优化ListView的性能,包括视图复用、ViewHolder模式、分批加载数据、图片优化及内存管理等。这些方法能够显著提升应用的响应速度和用户体验。 ... [详细]
  • 1:有如下一段程序:packagea.b.c;publicclassTest{privatestaticinti0;publicintgetNext(){return ... [详细]
  • 本文详细探讨了Java中的24种设计模式及其应用,并介绍了七大面向对象设计原则。通过创建型、结构型和行为型模式的分类,帮助开发者更好地理解和应用这些模式,提升代码质量和可维护性。 ... [详细]
  • 本文介绍了Java并发库中的阻塞队列(BlockingQueue)及其典型应用场景。通过具体实例,展示了如何利用LinkedBlockingQueue实现线程间高效、安全的数据传递,并结合线程池和原子类优化性能。 ... [详细]
  • 本文详细介绍了 Dockerfile 的编写方法及其在网络配置中的应用,涵盖基础指令、镜像构建与发布流程,并深入探讨了 Docker 的默认网络、容器互联及自定义网络的实现。 ... [详细]
  • 本文详细介绍了Java编程语言中的核心概念和常见面试问题,包括集合类、数据结构、线程处理、Java虚拟机(JVM)、HTTP协议以及Git操作等方面的内容。通过深入分析每个主题,帮助读者更好地理解Java的关键特性和最佳实践。 ... [详细]
  • 本文介绍如何使用 NSTimer 实现倒计时功能,详细讲解了初始化方法、参数配置以及具体实现步骤。通过示例代码展示如何创建和管理定时器,确保在指定时间间隔内执行特定任务。 ... [详细]
  • 本文介绍了在Windows环境下使用pydoc工具的方法,并详细解释了如何通过命令行和浏览器查看Python内置函数的文档。此外,还提供了关于raw_input和open函数的具体用法和功能说明。 ... [详细]
  • 高效解决应用崩溃问题!友盟新版错误分析工具全面升级
    友盟推出的最新版错误分析工具,专为移动开发者设计,提供强大的Crash收集与分析功能。该工具能够实时监控App运行状态,快速发现并修复错误,显著提升应用的稳定性和用户体验。 ... [详细]
author-avatar
ho世英雄
这个家伙很懒,什么也没留下!
PHP1.CN | 中国最专业的PHP中文社区 | DevBox开发工具箱 | json解析格式化 |PHP资讯 | PHP教程 | 数据库技术 | 服务器技术 | 前端开发技术 | PHP框架 | 开发工具 | 在线工具
Copyright © 1998 - 2020 PHP1.CN. All Rights Reserved | 京公网安备 11010802041100号 | 京ICP备19059560号-4 | PHP1.CN 第一PHP社区 版权所有