在JDK的多线程与并发库一文中, 提到了BlockingQueue实现了生产者-消费者模型 BlockingQueue是基于锁实现的, 而锁的效率通常较低. 有没有使用CAS机制实现的生产者-消费者? Disruptor就是这样. disruptor使用观察者模式, 主动将消息发送给消费者, 而不是 ...
分类：
其他好文 时间：
2017-05-01 09:55:47
阅读次数：
267
场景使用： 在HelloWorld的实例中，我们创建Disruptor实例，然后调用getRingBuffer方法去获取RingBuffer，其实在很多时候，我们可以直接使用RingBuffer，以及其他的API操作，看一下示例： 使用EventProcessor消息处理器； 使用WorkerPoo ...
分类：
其他好文 时间：
2017-03-09 20:36:25
阅读次数：
341
Disruptor术语 RingBuffer：被看作Disruptor最主要的组件，然而从2.0开始RingBuffer仅仅负责存储和更新在Disruptor中流通的数据。对一些特殊的使用场景能够被用户(使用其他数据结构)完全替代。 Sequence：Disruptor使用Sequence来表示一个 ...
分类：
其他好文 时间：
2017-03-07 20:47:59
阅读次数：
305
1 消息队列 Disruptor（https://github.com/LMAX-Exchange/disruptor） 2 微服务 3 数据库 Apache Common DbUtils（https://commons.apache.org/proper/commons-dbutils/） 4 序 ...
分类：
编程语言 时间：
2017-02-23 11:43:01
阅读次数：
155
1.术语 术语 英文单词 描述 内存屏障 Memory Barriers 是一组处理器指令，用于实现对内存操作的顺序限制。 In the Java Memory Model a volatile field has a store barrier inserted after a write to ...
分类：
其他好文 时间：
2017-02-04 18:32:11
阅读次数：
208
一、概述 disruptor对于处理并发任务很擅长，曾有人测过，一个线程里1s内可以处理六百万个订单，性能相当感人。 这个框架的结构大概是：数据生产端 --> 缓存 --> 消费端 缓存中的数据是主动发给消费端的，而不是像一般的生产者消费者模式那样，消费端去缓存中取数据。 可以将disruptor理 ...
分类：
其他好文 时间：
2017-01-05 13:37:53
阅读次数：
458
Disruptor是什么？Disruptor是一个高性能的异步处理框架，一个轻量级的JMS，和JDK中的BlockingQueue有相似处，但是它的处理速度非常快，获得2011年程序框架创新大奖，号称“一个线程一秒钟可以处理600W个订单”（这有点吓人吧），并且Disruptor不仅仅只有buffer，它提供的功能..
分类：
编程语言 时间：
2016-12-24 23:17:03
阅读次数：
446
转自 知乎 https://zhuanlan.zhihu.com/p/21355046 order从client端传入，decode后进行matching，一旦存在可成交的价格，就要publish到time series，并且把trade存到local的database里。如何handle这么大数量 ...
分类：
其他好文 时间：
2016-08-30 21:03:11
阅读次数：
228
在并发编程过程中，我们大部分的焦点都放在如何控制共享变量的访问控制上（代码层面），但是很少人会关注系统硬件及JVM底层相关的影响因素。前段时间学习了一个牛X的高性能异步处理框架 Disruptor，它被誉为“最快的消息框架”，其 LMAX 架构能够在一个线程里每秒处理6百万订单！在讲到 Disrup... ...
分类：
其他好文 时间：
2016-08-23 21:42:20
阅读次数：
200
为什么Disruptor不使用队列来实现RingBuffer 队列有两个指针，一个指向队头，一个指向队尾。如果有超过一个生产者想要往队列里放东西，尾指针就将成为一个冲突点，因为有多个线程要更新它。如果有多个消费者，那么头指针就会产生竞争，因为元素被消费之后，需要更新指针，所以不仅有读操作还有写操作了 ...
分类：
其他好文 时间：
2016-08-19 13:16:54
阅读次数：
124
