zoukankan      html  css  js  c++  java
  • disruptor 核心概念 二

    一、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!

  • 相关阅读:
    什么是枚举?有什么作用?有什么好处?
    java获取某个范围内的一个随机数
    java中普通代码块,构造代码块,静态代码块的区别及代码示例
    Oracle数据库迁移
    linux下修改文件权限
    <%@ include file="">和<jsp:include file="">区别
    JAVA常见异常解析
    jdk环境变量配置
    jstl中fmt标签详解
    jsp脚本元素
  • 原文地址:https://www.cnblogs.com/gyli20170901/p/10244180.html
Copyright © 2011-2022 走看看