一、Disruptor图解

 

二、disruptor核心概念

1.RingBuffer到底是啥？

正如名字所说的一样，他是一个环（首尾相接的环）

它用做在不同上下文（线程）间传递数据的buffer

RingBuffer拥有一个序号，这个序号指向数组中下一个可用的元素

Ringbugger:基于数组的缓存实现，也是创建sequencer与定义WaitStrtegy的入口

Disruptor:持有RingBuffer、消费者线程池Executor、消费者集合ConsumerRepository等引用

 

2.sequence

通过顺序递增的序号来编号，管理进行交换的数据（事件）

对数据（事件）的处理过程总是沿着序号逐个递增处理

一个Sequence用于跟踪标识某个特定的世界处理者（Ringbuffer/Producer/Consumer）的处理进度

Sequence可以看成是一个AtomicLong用于标识进度

还有另一个目的就是防止不同Sequence之间CPU缓存伪共享（Flase Sharing）的问题

 

3.Sequencer

Sequencer是Disruptor的核心 包含Sequence

此接口有两个实现类

SingleProducerSequencer

MultiProducerSequencer

主要实现生产者和消费者之间快速、正确的传递数据的并发算法

 

4.Sequence Barrier

用于保持对RingBuffer的Main Published Sequence(Producer)和Consumer之间的平衡关系；Sequence Barrier还定义了决定Consumer是否还有可处理的事件的逻辑

 

5.WaitStrategy

决定一个消费者将如何等待生产者将Event置入Disruptor！

主要的策略有：

BlockingWaitStrategy、SleepingWaitStrategy、YieldingWaitStrategy

BlockingWaitStrategy 是最低效的策略，但其对CPU的消耗最小并且在各种不同部署环境中能提供更加一致的性能表现

SleepingWaitStrategy 的性能表现跟BlockingWaitStrategy差不多，对CPU的消耗也类似，但其对生产者线程的影响最小，适合用于异步日志类似的场景

YieldingWaitStrategy 的性能是最好的，适合用于低延迟的系统。在要求极高性能且事件处理线数小于CPU逻辑核心数的场景中，推荐使用此策略；例如，CPU开启超线程的特性

 

6.Event

Event：从生产者到消费者过程中所处理的数据单元

7.EventProcessor

EventProcessor 主要事件循环，处理Disruptor中的Event，拥有消费者的Sequence

它有一个实现类是BatcheEventProcessor,包含了event loop 有效的实现，并且将回调到一个EventHandler接口的实现对象

 

8.EventHandler

EventHandler 由用户实现并且代表了Disruptor中的一个消费者的接口，也就是我们的消费者逻辑都需要写在这里

9.WorkProcessor

WorkProcessor 确保每个sequence只被一个processor消费，在同一个WorkPool中处理多个WorkProcessor不会消费同样的sequence!