Disruptor 2.0 - 所有的改变

本文涉及的产品
公共DNS(含HTTPDNS解析),每月1000万次HTTP解析
云解析 DNS,旗舰版 1个月
全局流量管理 GTM,标准版 1个月
简介: 这是 Trisha Gee 发表的 Disruptor 全解析系列博客的后续补充,原文链接是:http://mechanitis.blogspot.com/2011/08/disruptor-20-all-change-please.html​   Martin 最近公布了 Disruptor​ 的 2.0 版本​ —— 基本上,2.0 版自我们第一次开源以来有了如此多的改变,是需要把这些改变正式标记出来的时候了。
这是 Trisha Gee 发表的 Disruptor 全解析系列博客的后续补充,原文链接是: http://mechanitis.blogspot.com/2011/08/disruptor-20-all-change-please.html
 
Martin 最近公布了  Disruptor​ 的  2.0 版本​ —— 基本上,2.0 版自我们第一次开源以来有了如此多的改变,是需要把这些改变正式标记出来的时候了。Martin 的文章包含了所有的变化点,而我这一篇文章的目标是试图将之前的博客翻译成“新世界的语言”,因为把每篇博客都重写一遍得花很长时间。现在我知道用手工绘图表示一切的缺点了。
 
旧的世界
 
Disruptor 2.0 - 所有的改变
 
这是一个 Disruptor 消费结构的例子(具体来说,是菱形结构)。如果你对这个结构没有任何印象,可以随时退回去复习所有(但现在已经过时的)  Disruptor 细节​。
 
过去几个星期最显而易见的变化是:
 
1. 更新了命名规则。
2. 把 ProducerBarrier 的功能集成到了 RingBuffer 里。
3. 添加了  DisruptorWizard​ 到主代码库。
 
新世界秩序
 
Disruptor 2.0 - 所有的改变
 
你可以看到(图中的)基本原理几乎是相同的。它更简单,因为 ProducerBarrier 本身不再是一个实体 —— 取代它的是 PublishPort 接口,它由 RingBuffer 对象自身所实现。
 
类似的,名称 DependencyBarrier 代替了 ConsumerBarrier 用以明确这个对象的职责;而 Publisher(代替 Producer)与 EventProcessor 代替 Consumer 也更准确的反映了它们在做什么。用 Consumer 做名称总会有一点点混淆,因为 Consumer 从来没有从 RingBuffer 真正消费过什么。它只是一个简单的术语,我们希望用它能给队列实现中那些常见的东西赋予意义。
 
没有在图中标明的是 RingBuffer 节点的名称变化 —— 在旧世界,我们称之为 Entry,现在它们叫 Event,因为在另一端的是 EventProcesser.
 
批量重命名的目的不是让我的旧博客变得毫无价值,这样我还可以周而复始的继续写 Disruptor 博客。这远远不是我想要的——我还有其他,更大的东西要写。重命名的目的是让 Disruptor 的工作原理和用法变得更容易理解。尽管  我们​ 只用 Disruptor 做消息处理,但是我们在开源时希望它看上去更像一个通用解决方案,因此试图在命名规则里体现这一点。但事实上,用消息处理模型看起来更加直观。
 
更简便的组装
 
现在  Disruptor Wizard​ 是 Disruptor 自身的一部分。我那一整篇  有关组装​ 的文章都变得没什么意义了 —— 这是好事,真的,因为它有一点涉及太多细节了。
 
如今,如果你要创建一个菱形消费模式(例如, FuzzBuzz​ 性能测试那样的),代码会简单得多:
 
    DisruptorWizard dw = new DisruptorWizard<FizzBuzzEvent>(
                             ENTRY_FACTORY,
                             RING_BUFFER_SIZE,
                             EXECUTOR,
                             ClaimStrategy.Option.SINGLE_THREADED,
                             WaitStrategy.Option.YIELDING);
    FizzBuzzEventHandler fizzHandler = new FizzBuzzEventHandler(FIZZ);
    FizzBuzzEventHandler buzzHandler = new FizzBuzzEventHandler(BUZZ);
    FizzBuzzEventHandler fizzBuzzHandler = new FizzBuzzEventHandler(FIZZ_BUZZ);
    dw.handleEventsWith(fizzHandler, buzzHandler)
           .then(fizzBuzzHandler);
    RingBuffer ringBuffer = dw.start();
 
注意,这里是 Disruptor Wizard 的  Wiki 页面​。
 
其他的改变:性能提升
 
就像 Martin 在  他的文章​ 中提到的那样,他在 2.0 版中设法显著的(甚至更多!)提升了 Disruptor 的性能。
 
这个消息的简短版本是增加了一个崭新的类,Sequence,同时兼顾  Cacheline Padding 和消除  Memory Barrier​ 的需求。现在的 Cacheline Padding 做法稍有不同,因为,Java7 做了件可爱的事情,它设法“优化”掉了我们使用的过时技术。
 
目录
相关文章
|
2月前
|
存储 安全 API
源码解密协程队列和线程队列的实现原理(二)
源码解密协程队列和线程队列的实现原理(二)
35 1
|
2月前
|
存储 运维 API
源码解密协程队列和线程队列的实现原理(一)
源码解密协程队列和线程队列的实现原理(一)
40 1
|
7月前
|
Java 调度
【Java多线程】线程中几个常见的属性以及状态
【Java多线程】线程中几个常见的属性以及状态
53 0
|
存储 canal Java
两个例子带你入门 Disruptor
Disruptor 是英国外汇交易公司 LMAX 开发的一个高性能队列。很多知名开源项目里,比如 canal 、log4j2、 storm 都是用了 Disruptor 以提升系统性能 。 这篇文章,我们通过两个例子一步一个脚印帮助同学们入门 Disruptor 。
两个例子带你入门 Disruptor
|
缓存 安全 Java
Java多线程-Disruptor性能用测
Java多线程框架Disruptor
353 1
Java多线程-Disruptor性能用测
|
Java 调度
Java多线程(3)--线程的生命周期
Java多线程(3)--线程的生命周期
91 0
Java多线程(3)--线程的生命周期
|
缓存 网络协议 Java
【Java原理探索】教你如何使用「精巧好用」的DelayQueue(延时队列)
【Java原理探索】教你如何使用「精巧好用」的DelayQueue(延时队列)
182 0
|
安全 Java
Java多线程:线程属性
Java多线程:线程属性
Java多线程:线程属性
|
Java Maven
java多线程提交,如何按照时间顺序获取线程结果,看完你就懂了 | Java工具类
java多线程提交,如何按照时间顺序获取线程结果,看完你就懂了 | Java工具类
java多线程提交,如何按照时间顺序获取线程结果,看完你就懂了 | Java工具类