add 方法
arrayblockingqueue linkedblockingqueue 继承 abstractqueue 先offer offer失败抛出异常
priorityblockingqueue synchronousqueue delayqueue 则是 offer 方法
offer方法
arrayblockingqueue 定长数组 环queue
获取全局锁 putindex++,元素进队。 当putindex++ 和队列长度相等的时候归零 释放take等待数组满员,offer失败返回false
linkedblockingqueue 定容链表
获取put锁 元素进队 如果队列初始化—完成 唤醒一个等待线程 ,如果队列没满唤醒添加线程数组满员,offer失败返回false
priorityblockingqueue 数据组
获取全局锁 检查扩容(小于64乘2 大于64乘1.5) 添加元素到数组尾部 逐一冒泡 父节点=(index-1)/2 唤醒等待线程
delayqueue 引用privoityblockingqueue
获取全局锁(不知道为啥要用) privorityblockingqueue 进对
synchronousqueue 无界链表
无锁 内部通过transfer与cas的方式进行 tansfers 进对或者进栈
put方法
对于定容队列: 如果队列已满,线程等待。队列未满 offer进对
对应自动扩容队列: offer添加
poll方法
arrayblockingqueue
获取全局锁 数组内元素数量不为0时 弹出对尾元素。元素数量为0 返回空。不阻塞
linkedblockingqueue
获取出队锁 head指针右移 first元素的item置为null。不阻塞
priorityblockingqueue
获取全局锁 数组内元素数量不为0时 弹出队首元素,并用队尾元素作为root节点重排序。元素数量为0 返回空。不阻塞
delayqueue
获取全局锁 从priorityblockingqueue中peek0号元素 检查是否delay到期。元素不为null,且到期 privorityblockingqueue 弹出0号元素,否则返回空
synchronousqueue
queue内部使用 transferqueue或transferstack的方式进行同步阻塞式获取,获取元素出队,否则先自旋,自旋超时挂起线程等待被唤起
take方法
arrayblockingqueue
获取全局锁 数组内元素数量不为0时 弹出对尾元素。元素数量为0 挂起当前线程。阻塞等待被唤起
linkedblockingqueue
获取出队锁 数组内元素数量不为0时 head指针右移 first元素的item置为null。元素数量为0 挂起当前线程。阻塞等待被唤起
priorityblockingqueue
获取全局锁 数组内元素数量不为0时 弹出队首元素,并用队尾元素作为root节点重排序。元素数量为0 挂起当前线程。阻塞等待被唤起
delayqueue
获取全局锁 从priorityblockingqueue中peek0号元素 检查是否delay到期。元素不为null,且到期privorityblockingqueue 弹出0号元素,否则挂起当前线程。阻塞等待被唤起
synchronousqueue
queue内部使用 transferqueue或transferstack的方式进行同步阻塞式获取,获取元素出队,否则先自旋,自旋超时挂起线程等待被唤起
peek方法
arrayblockingqueue
获取全局锁 获取对应出对位置元素,对应元素并不出对。
linkedblockingqueue
获取出队锁 获取head.next的item元素
priorityblockingqueue
获取全局锁 数组元素数量为0返回空,否则返回index为0号元素
delayqueue
priorityblockingqueue peek
synchronousqueue
同步阻塞queue 内部步存储元素 peek始终为null