BlockingQueue
// 非阻塞方法:
boolean offer(e[,timeout, timeUnit]); // 添加,失败返回false;
E poll([timeout, timeUnit]); // 取出,失败返回null
// 阻塞线程方法:
put(e); // 添加,若空间不足则阻塞直到添加成功
E take(); // 取出,若为空则阻塞直到有数据
int drainTo(collection[,maxn]); // 取出所有可用对象,无须多次加锁或释放,可提效率
| 阻塞队列 | 特性 |
|---|---|
| ArrayBlockingQueue | 有界数组结构,为保证吞吐量默认不公平访问 |
| LinkedBlockingQueue | 链表(INT_MAX)结构,生产消费分锁以保证效率 |
| PriorityBlockingQueue | 无界队列,支持自定义***不稳定排序*** |
| SynchronousQueue | 空阻塞队列 |
| DelayQueue | 堆实现,支持延时获取,只有在超时后才能取出 |
| LinkedBlockingDeque | 双向链表,支持双向操作减少竞争 |
| LinkedTransferQueue | 无界链表transfer(e):• 若存在消费线程等待,则立刻将元素传递给消费者; • 否则元素插入队尾,阻塞生产线程,直到有消费者取走; tryTransfer(e):• 若存在消费线程等待,则立刻将元素传递给消费者; • 否则返回false,元素不进队列; tryTransfer(e,timeout,timeUnit):• 若存在消费线程等待,则立刻将元素传递给消费者; • 否则数据插入队尾,并等待指定时长,此中若被取走返回true,否则返回false; |
版权声明
本文仅代表作者观点,不代表百度立场。
本文系作者授权百度百家发表,未经许可,不得转载。


