disruptor demo(三) 复杂一点的例子

从中图可以看出需求是介样子的：生产者生产数据经过C1,C2处理完成后再到C3。 假设如下场景： 1、交易网关收到交易(P1)把交易数据发到RingBuffer中， 2、负责处理增值业务的消费者C1和负责数据存储的消费者C2负责处理交易 3、负责发送JMS消息的消费者C3在C1和C2处理完成后再进行处理。 1. [java]  view plain  copy package p1;   //POJ

>>阅读原文<<