Disruptor 分析

 1 public static void main(String[] args)throws Exception{
 2         EventFactory<LongEvent> eventFactory = new LongEventFactory();
 3         int ringBufferSize = 1024;
 4         ExecutorService executors = Executors.newCachedThreadPool();
 5         final Disruptor<LongEvent> disruptor = new Disruptor<LongEvent>(eventFactory, ringBufferSize, executors,ProducerType.SINGLE, new BlockingWaitStrategy());    
 6         //final Disruptor<IntEvent> disruptor = new Disruptor<IntEvent>(eventFactory, ringBufferSize, executors,ProducerType.MULTI, new BlockingWaitStrategy()); //多生产者
 7         Consumer consumer1 = new Consumer();
 8         Consumer consumer2 = new Consumer();
 9         EventHandlerGroup<LongEvent> firstLevel = disruptor.handleEventsWith(consumer1,consumer2);
10         Consumer consumer21 = new Consumer();
11         Consumer consumer22 = new Consumer();
12         EventHandlerGroup<LongEvent> secondLevel = firstLevel.then(consumer21,consumer22);
13         disruptor.start();    //启动disruptor,consumer开始等待，消费数据
14         Producer producer = new Producer(disruptor);
15         
16         //启动生产者
17         new Thread(producer).start();
18     }