消息队列全面解析

消息队列-消息中间件

阻塞队列

• 当阻塞队列是空时，从队列中获取元素的操作将会被阻塞
• 当阻塞队列是满时，往队列里添加元素的操作将会被阻塞
• 试图从空的阻塞队列中获取元素的 线程将会被阻塞，直到其他的线程往空的队列插入新的元素
• 试图往已满的阻塞队列新增元素的线程将会被阻塞，直到其他的线程从队列中移除一个或者多个元素或者清空队列后使队列重新变得空闲起来并后续新增
• 在多线程的领域：所谓阻塞，在某些情况下会挂起线程（阻塞），一旦条件满足，被挂起的线程又会自动被唤醒
• 为什么需要BlockingQueue
  1. 好处是我们不需要关心什么时候需要阻塞线程，什么时候需要唤醒线程，因为这一切BlockingQueue都给你一手包办了
• 在concurrent包发布以前，在多线程环境下，我们每个程序员都必须去自己控制这些细节，尤其还要兼顾效率和线程安全，而这会给我们的程序带来不小的复杂度

队列类分析

• ArrayBlockingQueue：由数组结构组成的有界阻塞队列
• LinkedBlockingQueue：由链表结构组成的有界（但是大小默认值是Integer.MAX_VALUE）阻塞队列
• PriorityBlockingQueue：支持优先排序的无界阻塞队列
• DelayQueue：使用优先级队列实现的的延迟无界阻塞队列
• SychronousQueue：不存储元素的阻塞队列，也即单个元素的队列
• LinkedTransferQueue：由链表结构组成的无界阻塞队列
• LinkedBlockingDeque：由链表结构组成的双向阻塞队列

用在哪里

1. 生产者消费者模式:1.传统版 2.阻塞队列版
2. 线程池
3. 消息中间件