标签：Disruptor 加锁 10 队列 初步 认识 RingBuffer 存储单元
Disruptor
背景介绍
Disruptor是英国外汇交易公司LMAX开发的一个高性能队列，研发的初衷是解决内存队列的延迟问题（在性能测试中发现竟然与I/O操作处于同样的数量级）。基于Disruptor开发的系统单线程能支撑每秒600万订单，2010年在QCon演讲后，获得了业界关注。2011年，企业应用软件专家Martin Fowler专门撰写长文介绍。同年它还获得了Oracle官方的Duke大奖。目前，包括Apache Storm、Camel、Log4j 2在内的很多知名项目都应用了Disruptor以获取高性能。
★需要特别指出的是，这里所说的队列是系统内部的内存队列，而不是Kafka这样的分布式队列。
技术介绍
Disruptor是基于无锁的并发“生产者 - 消费者模型”构建的。在保证逻辑正确的前提下，尽可能地提高队列在并发情况下的性能，Disruptor 采用了“两阶段写入”的方法。在写入数据之前，先加锁申请批量的空闲存储单元，之后往队列中写入数据的操作就不需要加锁了，写入的性能因此就提高了。Disruptor 对消费过程的改造，跟对生产过程的改造是类似的。它先加锁申请批量的可读取的存储单元，之后从队列中读取数据的操作也就不需要加锁了，读取的性能因此也就提高了（即在读和写之前均加锁，然后在真正的读和写过程中不加锁）。
对于生产者
对于生产者来说，它往队列中添加数据之前，先申请可用空闲存储单元，并且是批量地申请连续的 n 个（n≥1）存储单元。当申请到这组连续的存储单元之后，后续往队列中添加元素，就可以不用加锁了，因为这组存储单元是这个线程独享的。
对于消费者
对于消费者来说，处理的过程跟生产者是类似的。它先去申请一批连续可读的存储单元（这个申请的过程也是需要加锁的），当申请到这批存储单元之后，后续的读取操作就可以不用加锁了。
核心数据结构-RingBuffer
RingBuffer是一个环形数组，你可以把它当作在不同上下文（线程）间传递数据的buffer。
RingBuffer拥有一个序号，这个序号指向数组中下一个可用的元素。
随着你不停地填充这个buffer，这个序号会一直增长，直到绕过这个环（注意：图中的黑色数字代表的是序号值，不是数组的真正下标）。
若想找到数组中当前序号所指向的元素，可以通过mod操作获得。
序号 % arr.length = arrIndex
12 % 10 = 2
2代表->数组下标是2
事实上，上图中的Ringbuffer只有10个槽完全是个意外。如果槽的个数是2的N次方将更有利于基于二进制的机器运算。
2的N次方换成二进制就是1000，100，10，1这样的数字，
序号 & arr.length－1 = arrIndex，
比如一共有8槽，3&（8－1）=3，HashMap就是用这个方式来定位数组元素的，这种方式比取模的速度更快。
当另外一个服务通过nak (拒绝应答信号)告诉我们没有成功收到消息时，我们会从nak的那一个地方重新开始发送（因为RingBuffer不会删除已发送的数据，除非数据被覆盖了）。
收到10号nak，那就从10号重新开始发送：10、11、12。。。
优点
使用了数据，可以为数组预先分配好内存，使得数组对象一直存在，不会频繁的发生垃圾回收，此外，它也不会像链表那样，需要花时间在创建结点上，并且删除结点也是需要时间的，而RingBuffer没有删除操作，而是对原数据进行覆盖。
还未提到的点
RingBuffer的环重叠问题、如何对RingBuffer进行读写
标签：Disruptor,加锁,10,队列,初步,认识,RingBuffer,存储单元 来源： https://www.cnblogs.com/whyblogs/p/16242714.html
本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享； 2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关； 3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关； 4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除； 5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。