【BlockingQueue】BlockingQueue接口方法说明和区别
BlockingQueue在异步处理的时候经常用到它的存放和取出数据的操作,但是如存放也有add、offer等多个方法,这些方法有什么区别,这边用LinkedBlockingQueue作为实现测试一下。
存放
先上方法:
boolean add(E e);boolean offer(E e);void put(E e) throws InterruptedException;boolean offer(E e, long timeout, TimeUnit unit) throws InterruptedException;
从方法的声明可以看出点端倪,put方法是阻塞的,如果这个队列满了,那么它会一直阻塞等待,直到队列出现空位可以放元素,或者是线程被中断。
至于offer()和add(),看下面的代码:
BlockingQueue queue = new LinkedBlockingQueue(2);
queue.offer(1);
System.out.println(queue.size());
queue.offer(2);
System.out.println(queue.size());
queue.offer(3);
System.out.println(queue.size());
queue.add(4);
System.out.println(queue.size());输出:
1
2
2
Exception in thread "main" java.lang.IllegalStateException: Queue full
可以看出来,offer是一个投资人,就是试一下能不能在队列中放一个元素,尝试的时间可以设定,但是发现不行以后会马上终止,并且返回true或者false。而add是家暴,可以理解为强行加入元素,但是不能加入的时候(比如队列有长度限制并且已经达到长度),直接粗暴的抛出IllegalStateException进行警告。
取出
先上方法
E take() throws InterruptedException;E poll(long timeout, TimeUnit unit)throws InterruptedException;
然后举个例子
BlockingQueue queue = new LinkedBlockingQueue(2);
queue.offer(1);
System.out.println(queue.size());
queue.offer(2);
System.out.println(queue.size());
queue.poll(1, TimeUnit.SECONDS);
System.out.println(queue.size());
queue.poll(1, TimeUnit.SECONDS);
System.out.println(queue.size());
queue.poll(1, TimeUnit.SECONDS);
System.out.println(queue.size());
queue.take();
System.out.println(queue.size());输出:
1
2
1
0
0
(线程一直等待...)
可以看出来,poll方法也是投资人的方式,可以设定时间,然后在无法取出元素的时候果断返回false。而take方法就是一直阻塞等待有元素可以,或者线程被中断。
总结
以上是BlockingQueue中用到的关于存放和取出方法的举例,在LinkedBlockingQueue实现中,还有peek之类的方法,做一个总结放在下面。
方法 | 效果 | 是否阻塞 | 是否抛出异常 | 返回 |
---|---|---|---|---|
boolean add(E e) | 添加 | 否 | 队列满导致添加失败时抛出IllegalStateException | true/false |
boolean offer(E e) | 添加 | 否 | 否 | true/false |
boolean offer(E e, long timeout, TimeUnit unit) | 添加 | 是(指定时间) | 否 | true/false |
void put(E e) | 添加 | 是(无期限) | 阻塞线程中断时抛出InterruptedException | true/false |
E take() | 取出 | 是(无期限) | 阻塞线程中断时抛出InterruptedException | 头部元素 |
E poll(long timeout, TimeUnit unit) | 取出 | 是(指定时间) | 阻塞线程中断时抛出InterruptedException | 头部元素/null |
E remove() | 取出 | 否 | 队列为空时抛出NoSuchElementException | 头部元素 |
E peek() | 查看 | 否 | 否 | 头部元素/null |
E element() | 查看 | 否 | 队列为空时抛出NoSuchElementException | 头部元素 |
【BlockingQueue】BlockingQueue接口方法说明和区别相关推荐
- 抽象类和接口的联系与区别
抽象类和接口联系与区别 关键字: 抽象类与接口的区别 abstract class和interface是Java语言中对于抽象类定义进行支持的两种机制,正是由于这两种机制的存在,才赋予了Java强大的 ...
- Java中实现接口与继承的区别
** Java中实现接口与继承的区别 ** 首先,先来了解一下什么是接口和继承.接口一般是使用interface来定义的.接口定义同类的定义类似,分为接口的声明和接口体,其中接口体由常量定义和方法定义 ...
- 面试题:接口和抽象类的区别
区别一,两者表达的概念不一样.抽象类是一类事物的高度聚合,那么对于继承抽象类的子类来说,对于抽象类来说,属于"是"的关系:而接口是定义行为规范,因此对于实现接口的子类来说,相对于接 ...
- 【Android 多媒体开发】 MediaPlayer 状态机 接口 方法 解析
作者 : 韩曙亮 转载请著名出处 : http://blog.csdn.net/shulianghan/article/details/38487967 一. MediaPlayer 状态机 介绍 ...
- c#接口和抽象类的区别
一.抽象类: 抽象类是特殊的类,只是不能被实例化:除此以外,具有类的其他特性:重要的是抽象类可以包括抽象方法,这是普通类所不能的.抽象方法只能声明于抽象类中,且不包含任何实现,派生类必须覆 ...
- Iterator和ListIterator接口的使用和区别
1.Iterator接口 1.1.Iterator接口概述 java.util.Iterator 接口提供遍历任何 Collection 的接口.我们可以从一个 Collection 中使用迭代器方法 ...
- Java 接口和抽象类的区别
接口(interface)可以说成是抽象类的一种特例,接口中的所有方法都必须是抽象的.接口中的方法定义默认为public abstract类型,接口中的成员变量类型默认为public static f ...
- 接口方法上的注解无法被@Aspect声明的切面拦截的原因分析
转载自 接口方法上的注解无法被@Aspect声明的切面拦截的原因分析 前言 在Spring中使用MyBatis的Mapper接口自动生成时,用一个自定义的注解标记在Mapper接口的方法中,再利用@ ...
- java 关注公众号没有调接口_高频面试题:接口和抽象类的区别
作为一个基础的Java高频面试题,是所有Java面试者必须烂熟于心的.当然不能死记硬背,可以通过实际地写几个小demo,边实际操作边理解,既能感受到编程的快乐,更重要的是真的理解记住了二者的区别. 此 ...
最新文章
- 如何改进YOLOv3使其更好应用到小目标检测(比YOLO V4高出4%)
- Xilinx 推出 reVISION,继续拓展机器学习市场
- 自学Zabbix3.0版本以上资产清单inventory
- Matlab 进行离散时间信号序列的生成
- 操作系统 第二章【记录型信号量机制、独木桥问题】【MOOC答案】
- 用css3和ico图片实现火狐社区的分享图标
- 4_less中带参数混合
- ClickHouse留存、路径、漏斗、session实战
- 《统一沟通-微软-实战》-3-部署-Exchange 2010-3-证书-创建-导入-分配
- BZOJ2563 阿狸和桃子的游戏
- webApplicationContext 与servletContext
- IDEA 创建类注释模板
- 证件照处理软件(IDPhoto Processor)免费版 v3.2.10
- springboot - redis记录并统计网页浏览量
- 随笔之大学四年生活有感
- WebJars简介 —— 前端资源的jar包形式
- 计算机职业资格证书有哪些
- python-操作autocad之pyautocad包
- 视频转GIF图2.0动图制作软件,提供三种GIF尺寸选择
- 微信公众号开发之接收与发送消息