Disruptor本地线程队列_使用transProcessor处理器和WorkPool两种方式进行消费对比---线程间通信工作笔记005

然后我们再来看,这里的

EventProcessor消息处理器,和

WorkerPool消息处理器

 

可以看到我们说这个EventProdessor可以看作是生产者,用来生产数据的

WorkProcessor是消费者对吧,而一个WorkerPool可以说是一个线程池,而一个个的

WorkProcessor就是消费用的线程.可以看到多个WorkProcessor同时消费的时候,可以保证,

同一个sequence不被多个WorkProcessor消费

可以看到上面这个Trade就是交易的意思,我们现在用Disruptor来处理交易数据

可以看到有id 订单编号,有name,有price价格对吧还有个AtomicInteger这个 count先不用管

这个Trade就相当于我们之前说的Event,就是代表数据对吧.

数据Trade肯定需要有个Factory,来生产trade数据,这里我们直接在main中生产trade

首先buffer_size是环形缓冲区大小