Class BatchEventProcessor<T>

  • Type Parameters:
    T - event implementation storing the data for sharing during exchange or parallel coordination of an event.
    All Implemented Interfaces:
    EventProcessor, java.lang.Runnable

    public final class BatchEventProcessor<T>
    extends java.lang.Object
    implements EventProcessor
    Convenience class for handling the batching semantics of consuming entries from a RingBuffer and delegating the available events to an EventHandler.

    If the EventHandler also implements LifecycleAware it will be notified just after the thread is started and just before the thread is shutdown.