消息队列
2017-09-08 09:05
155 查看
队列
队列基础
基本概念Queue用于模拟队列这种数据结构。
队列通常是指“先进先出(FIFO)”的容器。
队列的头部保存在队列中存放时间最长的元素,尾部保存存放时间最短的元素。
新元素插入到队列的尾部,取出元素会返回队列头部的元素。
通常,队列不允许随机访问队列中的元素。
在java5中新增加了java.util.Queue接口,用以支持队列的常见操作。该接口扩展了java.util.Collection接口。* Queue使用时要尽量避免Collection的add()和remove()方法,而是要使用offer()来加入元素,使用poll()来获取并移出元素。它们的优点是通过返回值可以判断成功与否,add()和remove()方法在失败的时候会抛出异常。 如果要使用前端而不移出该元素,使用element()或者peek()方法。
Queue的常用方法
插入数据void add(Object e): 将指定元素插入到队列的尾部。
boolean offer(Object e): 将指定的元素插入此队列的尾部。当使用容量有限的队列时,此方法通常比add(Object e)有效。
移除
Object remove(): 获取队列头部的元素,并删除该元素。
Object poll(): 返回队列头部的元素,并删除该元素。如果队列为空,则返回null。
检查
object element(): 获取队列头部的元素,但是不删除该元素。
Object peek(): 返回队列头部的元素,但是不删除该元素。如果队列为空,则返回null。
双端队列
*Queue还有一个Deque接口,Deque代表一个“双端队列”,双端队列可以同时从两端删除或添加元素,因此Deque可以当作栈来使用。java为Deque提供了ArrayDeque实现类和LinkedList实现类。public static void main(String[] args) { ArrayDeque queue = new ArrayDeque(); queue.offer("春"); queue.offer("夏"); queue.offer("秋"); System.out.println(queue); System.out.println(queue.peek()); System.out.println(queue); System.out.println(queue.poll()); System.out.println(queue); }
在多线程下queue有什么问题?
最主要的问题,重复消费,造成数据混乱
阻塞队列
BlockingQueue,如果BlockQueue是空的,从BlockingQueue取东西的操作将会被阻断进入等待状态,直到BlockingQueue进了东西才会被唤醒.同样,如果BlockingQueue是满的,任何试图往里存东西的操作也会被阻断进入等待状态,直到BlockingQueue里有空间才会被唤醒继续操作BlockingQueue阻塞队列
ArrayBlockingQueue
LinkedBlockingQueue
常见操作
add():把anObject加到BlockingQueue里,即如果BlockingQueue可以容纳,则返回true,否则报异常
offer():表示如果可能的话,将anObject加到BlockingQueue里,即如果BlockingQueue可以容纳,则返回true,否则返回false.
put():把anObject加到BlockingQueue里,如果BlockQueue没有空间,则调用此方法的线程被阻断直到BlockingQueue里面有空间再继续.
poll():取走BlockingQueue里排在首位的对象,若不能立即取出,则可以等time参数规定的时间,取不到时返回null
take():取走BlockingQueue里排在首位的对象,若BlockingQueue为空,阻断进入等待状态直到Blocking有新的对象被加入为止
相关文章推荐
- 使用消息队列的 10 个理由
- C#之消息队列之自学笔记
- 为什么会需要消息队列(MQ)?
- 消息队列-ActiveMQ学习笔记(二)-点对点消息实现
- 使用事件和消息队列实现分布式事务
- redis 消息发布订阅与消息队列
- RabbitMQ消息队列(四):分发到多Consumer(Publish/Subscribe)
- [3]AMQP(高级消息队列协议) ----QPID JMS-0.9 API 对 SSL 的支持
- 消息队列的作用
- 消息队列的使用场景(转载c)
- 消息队列设计精要
- RabbitMQ消息队列(六):使用主题进行消息分发
- Web应用中的轻量级消息队列
- 进程间通信机制之一:消息队列
- 事件之消息队列
- 消息队列(Message Queue)简介及其使用
- ZeroMQ,史上最快的消息队列 —– ZMQ的学习和研究
- 消息队列设计精要
- 消息队列 (msgrcv, msgsnd)
- Linux消息队列编程实例