java queue源码_java源码解读--queue

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

接口结构

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

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16public interface extends Collection{

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

49public abstract class AbstractQueue

extends AbstractCollection

implements {

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(Collection extends 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

65public interface Deque extends {

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

2public 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(Collection extends E> c) {

allocateElements(c.size());

addAll(c);

}

调整数组大小1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17private 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];

}

add1

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

34public 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;

}

remove1

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

40public 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

33public 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

44private 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 < back) {

// 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 < t) { // 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

10private 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

18private 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;

}

标签:head,elements,java,int,queue,tail,源码,return,null

来源: https://www.cnblogs.com/petewell/p/11588764.html

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/283052.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

旧题新做:从idy的视角看数据结构

“今天你不写总结……&#xff01;&#xff01;&#xff01;” 额…… 还是讲我的吧。这些考试都是idy出的题。 20170121&#xff1a;DFS序、 ST表、线段树练习 这是第一次考数据结构。 Problem 1. setsum 1 second    给你一个长度为N 的整数序列&#xff0c;支持两种操作…

常用的 Java 工具类之 Apache 全家桶使用

平常我们在日常的开发中会一些通用的功能封装成一些工具类&#xff0c;以便之后复用。但是有些常用功能&#xff0c;业界已经存在&#xff0c;我们无需造轮子&#xff0c;只需直接使用或借用它们的 Api &#xff0c;构建我们的自己项目中工具类。这篇首先介绍平常用到的 Apache…

.NET MAUI实战 MessagingCenter

1.概要在.NET MAUI提供了消息机制&#xff0c;该机制为订阅/发布模式。发布-订阅模式是一种消息传递模式&#xff0c;在此模式下&#xff0c;发布者可在无需知道任何接收方&#xff08;称为订阅方&#xff09;的情况下发送消息。同样&#xff0c;订阅方可在不了解任何发布方的情…

elasticsearch 5.1 问题 ubuntu

1、can not run elasticsearch as root 切换到非root用户 2、main ERROR Could not register mbeans java.security.AccessControlException: access denied ("javax.management.MBeanTrustPermission" "register") 改变elasticsearch文件夹所有者到当前用…

洛谷——P1033 自由落体

https://www.luogu.org/problem/show?pid1033#sub 题目描述 在高为 H 的天花板上有 n 个小球&#xff0c;体积不计&#xff0c;位置分别为 0&#xff0c;1&#xff0c;2&#xff0c;…&#xff0e;n-1。在地面上有一个小车&#xff08;长为 L&#xff0c;高为 K&#xff0c;距…

java 接口防刷_java轻量级接口限流/防刷插件

简介call-limit提供接口限流、防刷的功能&#xff0c;插件基于spring开发&#xff0c;在应用应用的任何一个逻辑层皆可使用(web、service、dao)&#xff0c;插件支持单机应用下的限流和分布式应用的限流(分布式应用限流需要依赖redis)&#xff0c;在简单业务场景下插件可为大家…

【leetcode】521. Longest Uncommon Subsequence I

题目如下&#xff1a; 解题思路&#xff1a;本题有点意思。首先如果输入的两个字符串都为空&#xff0c;那么结果是-1&#xff1b;如果两个字符串长度不一样&#xff0c;那么结果是较长的字符串的长度&#xff0c;因为较长的字符串肯定是自身的子序列&#xff0c;但一定不是较短…

【问题】为什么 System.Timers.Timer 更改间隔时间后的第一次触发时间是设定时间的三倍?...

【问题】为什么 System.Timers.Timer 更改间隔时间后的第一次触发时间是设定时间的三倍&#xff1f;独立观察员 2022 年 9 月 4 日在编写 “Wifi 固定器 [1]” 程序时&#xff0c;按如下方式使用了定时器&#xff1a;// 声明&#xff1b; private Timer _Timer new Timer() { …

JS魔法堂:判断节点位置关系

一、前言                           在polyfill querySelectorAll 和写弹出窗时都需要判断两个节点间的位置关系&#xff0c;通过jQuery我们可以轻松搞定&#xff0c;但原生JS呢&#xff1f;下面我将整理各种判断方法&#xff0c;以供日后查阅。 二…

ChartCtrl源码剖析之——CChartAxis类

CChartAxis类用来绘制波形控件的坐标轴&#xff0c;这个源码相对较复杂&#xff0c;当初阅读的时候耗费了不少精力来理解源码中的一些实现细节。 CChartAxis类的头文件。 #if !defined(AFX_CHARTAXIS_H__063D695C_43CF_4A46_8AA0_C7E00268E0D3__INCLUDED_) #define AFX_CHARTA…

java如何输出线程的标识符_Java多线程面试题

1、在Java中什么是进程&#xff0c;什么是线程进程&#xff1a;进程是程序执行的一个实例&#xff0c;进程是线程的容器。程序是指令、数据及其组织形式的描述&#xff0c;进程是程序的实体。线程&#xff1a;有时被称为轻量级进程(Lightweight Process&#xff0c;LWP)&#x…

基于.net开发的自助餐饮系统

本文系 EMQ&Intel 联合举办的首届“中国物联网数据基础设施最佳案例评选大赛“个人开发者赛道一等奖作品。项目简介智能餐饮自助结算系统是一个由称重系统、显示屏、自助扫码盒和 Intel CPU 组成的智能自助结算终端&#xff0c;将装有菜品的托盘放到秤盘上结算&#xff0c;…

cacti 被监控机器snmp 配置

被监控服务器 需要查看网卡流量&#xff0c; 磁盘空间等信息。修改如下。vi /etc/snmp/snmpd.conf1、找到com2sec notConfigUser default public 改为&#xff1a;com2sec notConfigUser 192.168.1.1&#xff08;改成监控服务器的ip&#xff09; public 2、找到…

IntentService用法

IntentService 用完即走 IntentService&#xff0c;可以看做是Service和HandlerThread的结合体&#xff0c;在完成了使命之后会自动停止&#xff0c;适合需要在工作线程处理UI无关任务的场景。 IntentService 是继承自 Service 并处理异步请求的一个类&#xff0c;在 IntentSer…

TeaPot 用webgl画茶壶(3) 环境纹理和skybox

1 <html>2 <head>3 <title>TeaPolt</title>4 </head>5 6 <body οnlοad"main()">7 <canvas id"viewPort" width"600" height"600">8 This b…

java打包维护_java打包详解

from yahh2008的blog: http://www.matrix.org.cn/blog/yahh2008/兄弟&#xff0c;对java着迷吗&#xff0c;或者是为了自己的生计&#xff0c;不论怎样都欢迎你进入精彩java世界&#xff0c;welcome&#xff01;可能你刚刚对每个人说&#xff1a;Hello World&#xff01;也或者…

Linux高级文本处理之sed(三)

sed高级命令sed允许将多行内容读取到模式空间&#xff0c;这样你就可以匹配跨越多行的内容。本篇笔记主要介绍这些命令&#xff0c;它们能够创建多行模式空间并且处理之。其中&#xff0c;N/D/P这三个多行命令分别对应于小写的n/d/p命令&#xff0c;后者我们在上一篇已经介绍。…

如何在 C# 程序中注入恶意 DLL ?

一&#xff1a;背景 前段时间在训练营上课的时候就有朋友提到一个问题&#xff0c;为什么 Windbg 附加到 C# 程序后&#xff0c;程序就处于中断状态了&#xff1f;它到底是如何实现的&#xff1f;其实简而言之就是线程的远程注入&#xff0c;这一篇就展开说一下。二&#xff1a…

练习题|网络编程-socket开发

原文&#xff1a;https://www.cnblogs.com/shengyang17/p/8822745.html 1、什么是C/S架构&#xff1f; C指的是client&#xff08;客户端软件&#xff09;&#xff0c;S指的是Server&#xff08;服务端软件&#xff09;&#xff0c;C/S架构的软件&#xff0c;实现服务端软件与客…

okhttputils java_Java OkHttpUtils.post方法代码示例

import com.zhy.http.okhttp.OkHttpUtils; //导入方法依赖的package包/类Overridepublic void performRequestAsync(AyoRequest request, BaseResponseDispatcher responseHandler, BaseHttpCallback callback) {String url request.url;//基于OkHttpUtils辅助类//1 method决定…