读书人

Disruptor 源码分析(六) 一个消费者

发布时间: 2013-10-14 12:54:46 作者: rapoo

Disruptor 源码分析(6) 一个消费者和多个消费者的区别
disruptor一个消费者和多个消费者的区别

public RingBuffer<T> start()    {        for (ConsumerInfo consumerInfo : consumerRepository)        {            consumerInfo.start(executor);consumerInfo的start方法:public void start(final Executor executor)    {        executor.execute(eventprocessor);    }


说明每一个eventHandler都是有一个单独的线程去处理的.

从这里可以理解为一个eventHandler就是一个消费者,多个eventHandler就是多个消费者.
在程序上是没有什么区别的,都是通过线程池去跑的.

(上面说的是ConsumerInfo的默认实现类EventProcessorInfo的方式.)

读书人网 >开源软件

热点推荐