返回

Disruptor核心概念

发布时间:2022-11-29 16:18:05 223
# 数据

在Disruptor中,生产者不断生产数据,并将数据持续放入一个环形缓冲区RingBufferh中(底层是一个数组)。而消费者通过一个回调函数onEvent()监听着该RingBuffer。当生产者往RingBuffer中增加数据时,就会触发消费者的onEvent()方法,从而通知消费者去消费数据。

消费者的onEvent()方法由EventHandler接口提供。

在Disruptor中,缓冲区中的数据称为事件Event,消费者则是EventHandler(WorkHandler)的实现类。

Disruptor有以下三个特征:

1.基于事件驱动。

2.基于“观察者”模式、“生产者-消费者”模型。

3.可以在无锁的情况下实现网络的队列操作。

环形缓冲区RingBuffer实际是一个数组。RingBuffer可以通过next()方法获取一个序号,这个序号指向RingBuffer中的下一个元素的位置。与NIO中Buffer的position类似,当生产者不断地向RingBuffer读写数据时,RingBuffer获取的序号值就会一直增长,直到绕过这个环。

RingBuffer的大小必须是2的n次方,因此要找到RingBuffer中当前序号指向的元素位置,可以通过MOD快速定位。

当前序号指向的元素值= 当前元素的位置 % RingBuffer的长度。

也正是因为RingBuffer是数组,并且有一个容易预测的访问模式,所以CPU能够快速对RingBuffer中的数据进行预加载,从而大幅提升Disruptor的执行速度。

特别声明:以上内容(图片及文字)均为互联网收集或者用户上传发布,本站仅提供信息存储服务!如有侵权或有涉及法律问题请联系我们。
举报
评论区(0)
按点赞数排序
用户头像
精选文章
thumb 中国研究员首次曝光美国国安局顶级后门—“方程式组织”
thumb 俄乌线上战争,网络攻击弥漫着数字硝烟
thumb 从网络安全角度了解俄罗斯入侵乌克兰的相关事件时间线