Disruptor3.x Disruptor使用方式

Disruptor3.x Disruptor使用方式 EventHandler[] eventHandlers=new DisruptorEventHandler[]{new DisruptorEventHandler()}; DisruptorPublisher dp=new DisruptorPublisher(1024, eventHandlers); dp.start(); for (int i = 0; true; i++) { CDO cdo=new CDO(); cdo.setStringValue("strSN", i+"-"+DataUtil.uuid()); EventData data=new EventData(cdo); dp.publish(data); }