package cn.lonecloud.procum.disruptor;import cn.lonecloud.procum.Data;
import com.lmax.disruptor.RingBuffer;import java.nio.ByteBuffer;/*** @author lonecloud* @version v1.0* @date 下午3:02 2018/5/7*/
public class Producer {//队列private final RingBuffer<Data> dataRingBuffer;public Producer(RingBuffer<Data> dataRingBuffer) {this.dataRingBuffer = dataRingBuffer;}/*** 插入数据* @param s*/public void pushData(String s) {//获取下一个位置long next = dataRingBuffer.next();try {//获取容器Data data = dataRingBuffer.get(next);//设置数据data.setData(s);} finally {//插入dataRingBuffer.publish(next);}}
}

package cn.lonecloud.procum.disruptor;import cn.lonecloud.procum.Data;
import com.lmax.disruptor.WorkHandler;/*** @author lonecloud* @version v1.0* @date 下午3:01 2018/5/7*/
public class Customer implements WorkHandler<Data> {@Overridepublic void onEvent(Data data) throws Exception {System.out.println(Thread.currentThread().getName()+"---"+data.getData());}
}

package cn.lonecloud.procum.disruptor;import cn.lonecloud.procum.Data;
import com.lmax.disruptor.EventFactory;/*** @author lonecloud* @version v1.0* @date 下午3:02 2018/5/7*/
public class DataFactory implements EventFactory<Data> {@Overridepublic Data newInstance() {return new Data();}
}

package cn.lonecloud.procum.disruptor;import cn.lonecloud.procum.Data;
import com.lmax.disruptor.RingBuffer;
import com.lmax.disruptor.dsl.Disruptor;import java.util.UUID;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;/*** @author lonecloud* @version v1.0* @date 下午3:09 2018/5/7*/
public class Main {public static void main(String[] args) throws InterruptedException {//创建线程池ExecutorService service = Executors.newCachedThreadPool();//创建数据工厂DataFactory dataFactory = new DataFactory();//设置缓冲区大小，必须为2的指数，否则会有异常int buffersize = 1024;Disruptor<Data> dataDisruptor = new Disruptor<Data>(dataFactory, buffersize,service);//创建消费者线程dataDisruptor.handleEventsWithWorkerPool(new Customer(),new Customer(),new Customer(),new Customer(),new Customer(),new Customer(),new Customer());//启动dataDisruptor.start();//获取其队列RingBuffer<Data> ringBuffer = dataDisruptor.getRingBuffer();for (int i = 0; i < 100; i++) {//创建生产者Producer producer = new Producer(ringBuffer);//设置内容producer.pushData(UUID.randomUUID().toString());//Thread.sleep(1000);}}
}