zoukankan      html  css  js  c++  java
  • 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

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

  • 相关阅读:
    Jquery 中止正在执行的AJAX
    SQL语句添加说明
    MINIUI基本学习笔记
    ADO.NET使用事务简单实例
    通过反射将Datetable转换为泛型List<T>
    C语言七夕必备神器,待那烟花灿烂时,依旧做个单身狗
    七夕来了,请用C 语言和我交流
    C语言第一个字符串Hello,C语言基础教程之字符串
    无形细节最为致命,C语言中与零值比较那些小事儿
    C语言讨论象棋将帅问题,代码短又美!
  • 原文地址:https://www.cnblogs.com/shmilyToHu/p/6516535.html
Copyright © 2011-2022 走看看