BatchEventProcessor 在 lmax 中断模式中的作用是什么?
BatchEventProcessor<ValueEvent> eventProcessor
= new BatchEventProcessor(ringBuffer,屏障,处理程序);
EXECUTOR.execute( eventProcessor );
BatchEventProcessor 在 lmax 中断模式中的作用是什么?
BatchEventProcessor<ValueEvent> eventProcessor
= new BatchEventProcessor(ringBuffer,屏障,处理程序);
EXECUTOR.execute( eventProcessor );
BatchEventProcessor 是一个 eventProcessor 的实现,它监控每次调用时可用的事件数量。然后它将每个事件的实际处理委托给您的 eventHandler,并在批处理的最终事件已交付给您的事件处理程序时发出信号。
这个想法是,如果您想延迟从处理程序发布事件,例如将一组事件添加到单个较大的消息中。
如果我们从 Sam 的回答中谈论“将一组事件添加到一个更大的消息中”的任务,BatchEventProcessor 使我们可以做两件主要的事情: