AI
推荐
模板社区
专题
登录
免费注册
首页
流程图
详情
ArrayBlockingQueue源码
2021-08-18 10:02:46
5
举报
分享方式
免费使用
ArrayBlockingQueue
ArrayBlockingQueue
模版推荐
作者其他创作
大纲/内容
1
take
node线程1
while (count == 0)
firstWaiter
3
while (count == items.length)
notFull条件队列
注意:不能能并发put和take竞争的是同一把锁
将notFull条件队列中第一个节点移到AQS阻塞队列中，插入队尾，然后释放锁。线程的唤醒由阻塞队列的head节点唤醒它的下个节点
初始化 ArrayBlockingQueue queue=new ArrayBlockingQueue<>(2)lock = new ReentrantLock(false) notEmpty = lock.newCondition() notFull = lock.newCondition()
取出队列头部元素
lock.lockInterruptibly()
判断队列是否为空
nextWaiter
takeIndex
队列为空把当前线程放入notEmpty条件阻塞队列并挂起当前线程
notEmpty.await()
释放独占锁
4
lock.lockInterruptibly()
putIndex
dequeue
waitStatus
item数组
enqueue(x)入队后putIndex++
2
判断队列是否已满
已满将当前线程放入条件队列并挂起前线程
唤醒写线程操作的阻塞队列中第一个线程
notFull.signal()
notFull.await()
put(4）
结束
收藏
立即使用
Consumer运行原理
收藏
立即使用
Producer端核心流程（rocketmq）
收藏
立即使用
Broker基于raft协议的主从架构
收藏
立即使用
RocketMQ原理深入剖析
大大大大大
职业：程序员
去主页
Collect
Get Started
crawler.py
Collect
Get Started
Hotspot源码JVM启动执行main方法流程
Collect
Get Started
基础源码构建
Collect
Get Started
MCP源码分析
评论
0
条评论
下一页
Document
