Disruptor生产消费流程图
2020-04-27 11:25:54 5 举报Disruptor生产消费流程图
作者其他创作
大纲/内容
处理完成
否
依赖是否消费完
onSpinWait
存在有效数据
WaitStrategy.watFor
返回
EventProcessor(Runnable)
生产者
循环
SequenceBarrier
是
拉取数据
获取有效数据(waitFor)
处理数据(onEvent)
红色线：数据请求流程绿色线：数据返回流程橙色线：自旋逻辑
唤醒
返回数据
睡眠1毫秒
生产有可用数据
获取到数据
有
修改可用槽位
mutex.wait
RingBuffer
得到最大可用槽位
追赶上min消费者
notifyAll
生成发布数据
没有-Wait
next
唤醒All消费者
消费线程开始
自旋
获取最高连续可用槽位(Single&Multi不一样)
ProducerSequencer
职业：本科
0 条评论
下一页
