Study Disruptor Demo
Disruptor是一个开源的Java框架，它被设计用于在生产者—消费者（producer-consumer problem，简称PCP）问题上获得尽量高的吞吐量（TPS）和尽量低的延迟。Disruptor是LMAX在线交易平台的关键组成部分，LMAX平台使用该框架对订单处理速度能达到600万TPS，除金融领域之外，其他一般的应用中都可以用到Disruptor，它可以带来显著的性能提升。其实Disruptor与其说是一个框架，不如说是一种设计思路，这个设计思路对于存在“并发、缓冲区、生产者—消费者模型、事务处理”这些元素的程序来说，Disruptor提出了一种大幅提升性能（TPS）的方案。
===============================================================================
Usage: java -jar DisruptorDemo.jar TYPE{1|2} <CONSUMER THREAD NUM>
1.实现多生产者多消费者模式。
2.程序停止会终止生产者从缓存队列取出数据进行，并通知消费者将程序终止后还未处理的数据保存，避免程序停止导致数据丢失。
3.增加自定义消费异常处理。
4.测试10000000数据下的处理耗时。
5.增加等待策略。YieldingWaitStrategy
6.采用protobuf协议生产消费数据，创建pb协议:
cd pb
makeproto.bat
===============================================================================
BlockQueue: 1742ms/10,000,000pv = 5,740,000
Disruptor: 173ms/10,000,000pv = 57,803,000
===============================================================================
学习更新中......