并发编程之Disruptor-2.核心介绍

1.Disruptor核心组件

• RingBuffer
• Sequence
• Sequencer
• Sequence Barrier
• WaitStrategy
• Event
• EventProcessor
• EventHandler
• WorkProcessor

2.RingBuffer介绍

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

• Disruptor: 持有RingBuffer、消费者线程工厂ThreadFactory、消费者集合ConsumerRepository等引用

3.Sequence介绍

• 通过顺序递增的序号来编写，管理进行交换的数据(事件)

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

• 一个Sequence用于跟踪标识某个特定的事件处理者(RingBuffer/Producer/Consumer)的处理进度

• Sequence可以看成是一个AtomicLong用于表示进度

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

4.Sequencer介绍

• Sequencer是Disruptor的真正核心

• 此接口有两个实现类

  • SingleProducerSequencer
  • MultiProducerSequencer

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

5.Sequence Barrier介绍

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

6.WaitStrategy介绍

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

• 主要的等待策略有

  • BlockingWaitStrategy
    • 最低效的策略，但其对CPU的消耗最小并且在各种不同部署环境中能提供更加一致的性能表现
  • SleepingWaitStrategy
    • 性能与BlockingWaitStrategy差不多，对CPU的消耗也类似，但其对生产者线程的影响最小，适合用于异步日志类似的场景
  • YieldingWaitStrategy
    • 性能最好，适用于低延迟的系统。在要求极高性能且事件处理线数小于CPU逻辑核心数的场景中，推荐使用此策略;例如，CPU开启超线程的特性。无锁并行。

7.Event介绍

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

• Disruptor中没有代码表示Event，因为它完全是由用户定义的

8.EventProcessor

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

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

9.EventHandler

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

10.WorkProcessor

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

11.disruptor图解

Disruptor图解.png