首页 > 代码库 > Disruptor底层实现讲解与RingBuffer数据结构讲解

Disruptor底层实现讲解与RingBuffer数据结构讲解

 Disruptor术语

  • RingBuffer:被看作Disruptor最主要的组件,然而从2.0开始RingBuffer仅仅负责存储和更新在Disruptor中流通的数据。对一些特殊的使用场景能够被用户(使用其他数据结构)完全替代。
  • Sequence:Disruptor使用Sequence来表示一个特殊组件处理的序号。和Disruptor一样,每个消费者(EventProcessor)都维持着一个Sequence。大部分的并发代码依赖这些Sequence值的运转,因此Sequence支持多种当前为AtmoicLong类的特性。
  • Sequencer:这是Disruptor真正的核心。实现了这个接口的两种生产者(单生产者和多生产者)均实现了所有的并发算法,为了在生产者和消费者之间进行准确快速的数据传递。
  • SequenceBarrier:由Sequencer生产,并且包含了已经发布的Sequence的引用,这些的Sequence源于Sequencer和一些独立的消费者的Sequence。它包含了觉得是否有供消费者来消费的Event的逻辑。
  • WaitStrategy:决定一个消费者将如何等待生产者将Event置入Disruptor。
  • Event:从生产者到消费者=过程中所处理的数据单元。Disruptor中没有代码表示Event,因为它完全是由用户定义的
  • EventProcessor:主要事件循环,处理Disruptor中的Event,并且拥有消费者的Sequence。它有一个实现类是BatchEventProcessor,包含了event loop有效的实现,并且将回调到以恶搞EventHandler接口的实现对象。
  • EventHandler:由用户实现并且代表Disruptor中的一个消费者的接口。
  • Producer:由用户实现,它调用RingBufffer来插入事件(Event),在Disruptor中没有相应的实现代码,由用户实现。
  • WorkProcessor:确保每个sequence只被一个Processor消费,在同一个WorkPool中的处理多个WorkProcessor不会消费同样的sequence。
  • WorkerPool:一个WorkProcessor池,其中WorkProcessor将消费Sequence,所以任务可以在实现WorkHandler接口的worker池间移交。
  • LifecycleAware:当BatchEventProcessor启动和停止时,于实现这个接口用于接收通知。

Disruptor印象

技术分享

理解RingBuffer

 技术分享

技术分享

技术分享

 后面呢,我们来看一下跟上一次不同的一种实现,比上一次要简单很多,

主要是produer的类不一样,下面贴一下新的producer类:

技术分享

前面是我们自己实现的,现在这种是官网推荐的模式,简化了onData的步骤,这种实现,定义了一个EventTranslatorOneArg

对象,下面这个内部类主要就是做生产数据进行填充的。

 

Disruptor底层实现讲解与RingBuffer数据结构讲解