packageorg.skywalking.apm.agent.core.datacarrier.performance.comparetest.disruptor;importcom.lmax.disruptor.EventHandler;/** * Created by wusheng on 2016/11/24. */publicclassDataEventHandlerimplementsEventHandler<Data>{publiclongcounter=0;@OverridepublicvoidonEvent(Datadata,longsequence,booleanendOfBatch)throwsException{counter++;System.out.println("handler:"+data.getValue1());if(counter==TestDisruptor.totalSize){System.out.println("time cost:"+(System.currentTimeMillis()-TestDisruptor.startTime));TestDisruptor.isEnd=true;}}}