上一篇学习了ExecutorService和其它相关类的源码,本篇要学习的BlockingQueue中的源码,as always,先上类图
其实继承(实现)的层次比较简单,我们只要需要先学习一下BlockingQueue中的方法:
public interface BlockingQueueextends Queue { boolean add(E e);--往队列中插入一个对象,队列满了会抛异常 boolean offer(E e);--同上,区别是队列满了会返回false void put(E e) throws InterruptedException;--插入一个元素,满了就等待 boolean offer(E e, long timeout, TimeUnit unit) throws InterruptedException;--规定时间内插入元素 E take() throws InterruptedException;--弹出队首 E poll(long timeout, TimeUnit unit) throws InterruptedException;--规定时间内弹出队首 int remainingCapacity();--队列剩余大小 boolean remove(Object o);--删除一个equals o的对象 public boolean contains(Object o);--是否包含o int drainTo(Collection c);--把队列迁移到另外一个collection结构中 int drainTo(Collection c, int maxElements);--迁移,有个最大迁移数量}
其实除了poll和offer 其它方法一般我们是用不到的,所以还是很简单的接口定义。下面去看一下具体的几个实现类。
ArrayBlockingQueue--声明时就确定大小的队列,fifo方式。(方法基本和接口一致,没有特别要说明的内容)
LinkedBlockingQueue--链表实现的queue-remove效率会高一些
PriorityBlockingQueue--优先级队列
SynchronousQueue--阻塞队列,必须拿走一个才能放进来一个,也就是最多只有一个~
DelayQuque--就是放进去的内容,延迟时间到了后才可以获得
--
LinkedBlockDeque--双端队列 :offerFirst/offerLast,pollFirst/pollLast
LinkedTransferQueue--类似LinkedUnBlockedQueue,其实就是transfer方法有人再等待队列内容就直接给他这个元素,没人在等就放在队列里面。也就是效率会更高。