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
网友评论