jjzjj

TwitterStatusReceivedEvent

全部标签

java - Disruptor - 未调用 EventHandlers

我正在玩弄Disruptor框架,我发现我的事件处理程序没有被调用。这是我的设置代码:privatestaticfinalintBUFFER_SIZE=1024*8;privatefinalExecutorServiceEXECUTOR=Executors.newSingleThreadExecutor();privatevoidinitializeDisruptor(){if(disruptor!=null)return;disruptor=newDisruptor(TwitterStatusReceivedEvent.EVENT_FACTORY,EXECUTOR,newSingle