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

Posted 2020-09-03 小~虎

 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

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