技术标签: # 数据结构
今天要来讲一下java里的队列,队列,顾名思义,排队的列,既然按排队形来做的话,生活中的银行排队啊,上车排队啊,都是先到先办理或者先上车,队列存取数据列也一样,这就是先进先出,使用队列的规则是:使用队素时,数据元素只能从表的一端进入队列,另一端出队列。
称进入队列的一端为“队尾”,出队列的一端为“队头”。数据元素全部从队尾陆续进队列,由对头陆续出队列。
特点:先进先出
效率:插入数据项和移除数据项的时间复杂度都是O(1),因为插入是一个一个而且只能在一端插入,取出也只能一个一个从一头取,这样不用循环一次取一次存就可以得到复杂度就是O(1)。
基于数组实现的一个有界的阻塞队列,在创建ArrayBlockingQueue对象时必须指定容器大小。并且可以指定公平性和非公平性,默认情况下为非公平的,即不保证等待时间最长的队列最优先能够访问队列。
为什么是有界的?
看下图不指定容量会报错,那么指定了容量就是有界的。
为什么可以支持公平锁和非公平锁?
我随便拿个示例调用一个队列里的一个方法点进去
用的是ReentrantLock,ReentrantLock本身的功能是有支持公平锁和非公平锁的
下面代码示例下ArrayBlockingQueue怎么使用?
因为ArrayBlockingQueue存储和移除数据有三种情况,异常,阻塞,非阻塞
先演示存储满了再进行存储异常的情况
public class BlockingQueueDemo {
private int queueSize = 10;
private ArrayBlockingQueue<Integer> queue = new ArrayBlockingQueue<Integer>(queueSize);
//生产者
class Producer extends Thread {
@Override
public void run() {
for (int i = 0; i < queueSize + 1; i++) {
queue.add(i);
System.out.println("向队列中添加元素,队列剩余空间:" + (queueSize - queue.size()));
}
}
}
public static void main(String[] args) {
BlockingQueueDemo blockingQueueDemo = new BlockingQueueDemo();
Producer producer = blockingQueueDemo.new Producer();
producer.start();
}
}
我指定了存储10个数字,然后我要存储11个,那么就会报错,可以看出add()方法是存储满了就抛异常的方式
再来一个取元素,元素没有了,抛异常的代码情况
public class BlockingQueueDemo {
private int queueSize = 10;
private ArrayBlockingQueue<Integer> queue = new ArrayBlockingQueue<Integer>(queueSize);
class costormer extends Thread {
@Override
public void run() {
queue.remove();
System.out.println("向队列中取出一个元素,队列剩余:" + queue.size() + "个元素");
}
}
public static void main(String[] args) {
BlockingQueueDemo blockingQueueDemo = new BlockingQueueDemo();
costormer costormer = blockingQueueDemo.new costormer();
costormer.start();
}
}
队列里一个数据都没有,获取元素抛出没有元素异常,由此可见remove()是获取数据抛异常的方式
以上是异常的情况。
public class BlockingQueueDemo {
private int queueSize = 10;
private ArrayBlockingQueue<Integer> queue = new ArrayBlockingQueue<Integer>(queueSize);
//生产者
class Producer extends Thread {
@Override
public void run() {
for (int i = 0; i < queueSize + 1; i++) {
try {
queue.put(i);
System.out.println("向队列中添加元素,队列剩余空间:" + (queueSize - queue.size()));
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
public static void main(String[] args) {
BlockingQueueDemo blockingQueueDemo = new BlockingQueueDemo();
Producer producer = blockingQueueDemo.new Producer();
producer.start();
}
}
可以看到存储满了就会一直阻塞等待,直到队列元素被取出才会停止阻塞,由此可见存储数据的put()是有阻塞功能的。
取元素阻塞示例
public class BlockingQueueDemo {
private int queueSize = 10;
private ArrayBlockingQueue<Integer> queue = new ArrayBlockingQueue<Integer>(queueSize);
class costormer extends Thread {
@Override
public void run() {
try {
queue.take();
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("向队列中取出一个元素,队列剩余:" + queue.size() + "个元素");
}
}
public static void main(String[] args) {
BlockingQueueDemo blockingQueueDemo = new BlockingQueueDemo();
costormer costormer = blockingQueueDemo.new costormer();
costormer.start();
}
当前队列一个元素没有,取数据的时候就被阻塞一直等待了,程序一直没有退出操作,由此可见take()是取出阻塞操作的
public class BlockingQueueDemo {
private int queueSize = 10;
private ArrayBlockingQueue<Integer> queue = new ArrayBlockingQueue<Integer>(queueSize);
//生产者
class Producer extends Thread {
@Override
public void run() {
for (int i = 0; i < queueSize + 1; i++) {
Boolean issuccess = queue.offer(i);
if (issuccess) {
System.out.println("向队列中添加元素,队列剩余空间:" + (queueSize - queue.size()));
} else {
System.out.println("队列已满!");
}
}
}
}
public static void main(String[] args) {
BlockingQueueDemo blockingQueueDemo = new BlockingQueueDemo();
Producer producer = blockingQueueDemo.new Producer();
producer.start();
}
}
区别相信大家也看出来了,满了的情况不会抛出异常,也不会阻塞,这种就是成功存储就返回true,队列满了不能存储就返回false了。
取数据非阻塞示例
public class BlockingQueueDemo {
private int queueSize = 10;
private ArrayBlockingQueue<Integer> queue = new ArrayBlockingQueue<Integer>(queueSize);
class costormer extends Thread {
@Override
public void run() {
Object obj = queue.poll();
if (obj == null) {
System.out.println("队列无数据!");
} else {
System.out.println("向队列中取出一个元素,队列剩余:" + queue.size() + "个元素");
}
}
}
public static void main(String[] args) {
BlockingQueueDemo blockingQueueDemo = new BlockingQueueDemo();
costormer costormer = blockingQueueDemo.new costormer();
costormer.start();
}
}
由此可见poll()方法是队列没有数据获取时不阻塞,不抛异常返回null的一种方式。
总结一下:
ArrayBlockingQueue异常:
1.1 插入->队列满时再进行添加数据会抛出IllegalStateException异常。
代表方法:add()
1.2 移除->队列null时会抛出NoSuchElementException异常。
代表方法:remove(),element()
ArrayBlockingQueue阻塞:
1.1 插入->队列满再添加数据会堵塞
代表方法:put()
1.2 移除并获取->队列null时会堵塞
代表方法:take()
ArrayBlockingQueue非阻塞:
1.1 插入->队列满时再进行添加,就返回false
代表方法:offer()
1.2 移除并获取->队列为null,返回null
代表方法:poll(),peek()
基于链表实现的一个可选有界阻塞队列,在创建LinkedBlockingQueue对象时如果不指定容量大小,则默认大小为Integer.MAX_VALUE。
数据结构从源码中看是单链表结构
阻塞、不阻塞、异常都是和ArrayBlockingQueue是一致的,这里就不在演示了
PriorityBlockingQueue的实现使用了基于数组的平衡二叉堆(小的在上,大的在下方,即最小堆)优先级阻塞队列,可选有界队列,它会按照元素的优先级对元素进行排序,按照优先级顺序出队,每次出队的元素都是优先级最高的元素。
在阻塞和不阻塞和异常都是跟上述方法一样,唯一不同的是优先级排序的实现方式上。大家可以自行学习,这里就不再介绍了
DelayQueue比较特殊,它是一个BlockingQueue+PriorityQueue+Delayed的实现方式,可以这样说DelayQueue是使用了优先队列实现的BlockingQueue
一种延时阻塞队列,DelayQueue中的元素只有当其指定的延迟时间到了,才能够从队列中获取该元素。DelayQueue是一个无界队列,因此往队列插入数据的操作(生产者)永远不会被阻塞,而只有获取数据的操作(消费者)才会被阻塞。
虽然DelayQueue中也有put这样的堵塞方法,但是put里调用的是没有进行阻塞offer的方法。
SynchronousQueue的特点是只能容纳一个元素,同时SynchronousQueue使用了两种模式来管理元素,一种是使用先进先出的队列,一种是使用后进先出的栈,选用哪种模式可以通过构造函数来指定。(不常用)
非阻塞队列实现方式是使用循环CAS,非阻塞队列和阻塞队列的区别就只是方法不同,阻塞id会有take等一些存储或获取阻塞的方法,非阻塞则没有阻塞的方法。
数组结构队列,底层数组实现,且双向操作,既可以向头添加数据也可以向尾添加数据,既可以头部取数据也可以尾部取数据。使用方式都和阻塞队列都一样
优先级非阻塞队列,方法都是类似的不多说了。
是基于链表的非阻塞队列,底层是通过链表来实现的,非阻塞方法和ArrayDeque类似,只是它只能向队列尾部添加数据,所以没有Last和First方法。
其实大家自己代码测试的时候就可以发现,非阻塞的队列是没有阻塞的那些方法的
文章浏览阅读3.2k次。本文研究全球与中国市场分布式光纤传感器的发展现状及未来发展趋势,分别从生产和消费的角度分析分布式光纤传感器的主要生产地区、主要消费地区以及主要的生产商。重点分析全球与中国市场的主要厂商产品特点、产品规格、不同规格产品的价格、产量、产值及全球和中国市场主要生产商的市场份额。主要生产商包括:FISO TechnologiesBrugg KabelSensor HighwayOmnisensAFL GlobalQinetiQ GroupLockheed MartinOSENSA Innovati_预计2026年中国分布式传感器市场规模有多大
文章浏览阅读1.1k次,点赞2次,收藏12次。常用组合逻辑电路结构——为IC设计的延时估计铺垫学习目的:估计模块间的delay,确保写的代码的timing 综合能给到多少HZ,以满足需求!_基4布斯算法代码
文章浏览阅读3.3k次,点赞3次,收藏5次。OpenAI Manager助手(基于SpringBoot和Vue)_chatgpt网页版
文章浏览阅读2.2k次。USACO自1992年举办,到目前为止已经举办了27届,目的是为了帮助美国信息学国家队选拔IOI的队员,目前逐渐发展为全球热门的线上赛事,成为美国大学申请条件下,含金量相当高的官方竞赛。USACO的比赛成绩可以助力计算机专业留学,越来越多的学生进入了康奈尔,麻省理工,普林斯顿,哈佛和耶鲁等大学,这些同学的共同点是他们都参加了美国计算机科学竞赛(USACO),并且取得过非常好的成绩。适合参赛人群USACO适合国内在读学生有意向申请美国大学的或者想锻炼自己编程能力的同学,高三学生也可以参加12月的第_usaco可以多次提交吗
文章浏览阅读394次。1.1 存储程序1.2 创建存储过程1.3 创建自定义函数1.3.1 示例1.4 自定义函数和存储过程的区别1.5 变量的使用1.6 定义条件和处理程序1.6.1 定义条件1.6.1.1 示例1.6.2 定义处理程序1.6.2.1 示例1.7 光标的使用1.7.1 声明光标1.7.2 打开光标1.7.3 使用光标1.7.4 关闭光标1.8 流程控制的使用1.8.1 IF语句1.8.2 CASE语句1.8.3 LOOP语句1.8.4 LEAVE语句1.8.5 ITERATE语句1.8.6 REPEAT语句。_mysql自定义函数和存储过程
文章浏览阅读188次。半导体二极管——集成电路最小组成单元。_本征半导体电流为0
文章浏览阅读2.8k次,点赞3次,收藏18次。游戏水面特效实现方式太多。咱们这边介绍的是一最简单的UV动画(无顶点位移),整个mesh由4个顶点构成。实现了水面效果(左图),不动代码稍微修改下参数和贴图可以实现岩浆效果(右图)。有要思路是1,uv按时间去做正弦波移动2,在1的基础上加个凹凸图混合uv3,在1、2的基础上加个水流方向4,加上对雾效的支持,如没必要请自行删除雾效代码(把包含fog的几行代码删除)S..._unity 岩浆shader
文章浏览阅读5k次。广义线性模型是线性模型的扩展,它通过连接函数建立响应变量的数学期望值与线性组合的预测变量之间的关系。广义线性模型拟合的形式为:其中g(μY)是条件均值的函数(称为连接函数)。另外,你可放松Y为正态分布的假设,改为Y 服从指数分布族中的一种分布即可。设定好连接函数和概率分布后,便可以通过最大似然估计的多次迭代推导出各参数值。在大部分情况下,线性模型就可以通过一系列连续型或类别型预测变量来预测正态分布的响应变量的工作。但是,有时候我们要进行非正态因变量的分析,例如:(1)类别型.._广义线性回归模型
文章浏览阅读69次。环境保护、 保护地球、 校园环保、垃圾分类、绿色家园、等网站的设计与制作。 总结了一些学生网页制作的经验:一般的网页需要融入以下知识点:div+css布局、浮动、定位、高级css、表格、表单及验证、js轮播图、音频 视频 Flash的应用、ul li、下拉导航栏、鼠标划过效果等知识点,网页的风格主题也很全面:如爱好、风景、校园、美食、动漫、游戏、咖啡、音乐、家乡、电影、名人、商城以及个人主页等主题,学生、新手可参考下方页面的布局和设计和HTML源码(有用点赞△) 一套A+的网_垃圾分类网页设计目标怎么写
文章浏览阅读614次,点赞7次,收藏11次。之前找到一个修改 exe 中 DLL地址 的方法, 不太好使,虽然能正确启动, 但无法改变 exe 的工作目录,这就影响了.Net 中很多获取 exe 执行目录来拼接的地址 ( 相对路径 ),比如 wwwroot 和 代码中相对目录还有一些复制到目录的普通文件 等等,它们的地址都会指向原来 exe 的目录, 而不是自定义的 “lib” 目录,根本原因就是没有修改 exe 的工作目录这次来搞一个启动程序,把 .net 的所有东西都放在一个文件夹,在文件夹同级的目录制作一个 exe._.net dll 全局目录
文章浏览阅读1.5k次。本文为转载,原博客地址:http://blog.csdn.net/hujingshuang/article/details/46910259简介 BRIEF是2010年的一篇名为《BRIEF:Binary Robust Independent Elementary Features》的文章中提出,BRIEF是对已检测到的特征点进行描述,它是一种二进制编码的描述子,摈弃了利用区域灰度..._breif description calculation 特征点
文章浏览阅读4.1k次,点赞21次,收藏79次。本文是《基于SpringBoot的房屋租赁管理系统》的配套原创说明文档,可以给应届毕业生提供格式撰写参考,也可以给开发类似系统的朋友们提供功能业务设计思路。_基于spring boot的房屋租赁系统论文