T
- the type of entry used by the event processors.public class EventHandlerGroup<T> extends Object
EventProcessor
s used as part of the Disruptor
.Modifier and Type | Method and Description |
---|---|
EventHandlerGroup<T> |
and(EventHandlerGroup<T> otherHandlerGroup)
Create a new event handler group that combines the consumers in this group with otherHandlerGroup.
|
EventHandlerGroup<T> |
and(EventProcessor... processors)
Create a new event handler group that combines the handlers in this group with processors.
|
SequenceBarrier |
asSequenceBarrier()
Create a dependency barrier for the processors in this group.
|
EventHandlerGroup<T> |
handleEventsWith(EventHandler<T>... handlers)
Set up batch handlers to handle events from the ring buffer.
|
EventHandlerGroup<T> |
handleEventsWithWorkerPool(WorkHandler<T>... handlers)
Set up a worker pool to handle events from the ring buffer.
|
EventHandlerGroup<T> |
then(EventHandler<T>... handlers)
Set up batch handlers to consume events from the ring buffer.
|
EventHandlerGroup<T> |
thenHandleEventsWithWorkerPool(WorkHandler<T>... handlers)
Set up a worker pool to handle events from the ring buffer.
|
public EventHandlerGroup<T> and(EventHandlerGroup<T> otherHandlerGroup)
otherHandlerGroup
- the event handler group to combine.public EventHandlerGroup<T> and(EventProcessor... processors)
processors
- the processors to combine.public EventHandlerGroup<T> then(EventHandler<T>... handlers)
EventProcessor
in this group has processed the event.
This method is generally used as part of a chain. For example if the handler A
must
process events before handler B
:
dw.handleEventsWith(A).then(B);
handlers
- the batch handlers that will process events.EventHandlerGroup
that can be used to set up a event processor barrier over the created event processors.public EventHandlerGroup<T> thenHandleEventsWithWorkerPool(WorkHandler<T>... handlers)
EventProcessor
in this group has processed the event. Each event will be processed
by one of the work handler instances.
This method is generally used as part of a chain. For example if the handler A
must
process events before the worker pool with handlers B, C
:
dw.handleEventsWith(A).thenHandleEventsWithWorkerPool(B, C);
handlers
- the work handlers that will process events. Each work handler instance will provide an extra thread in the worker pool.EventHandlerGroup
that can be used to set up a event processor barrier over the created event processors.public EventHandlerGroup<T> handleEventsWith(EventHandler<T>... handlers)
EventProcessor
in this group has processed the event.
This method is generally used as part of a chain. For example if the handler A
must
process events before handler B
:
dw.after(A).handleEventsWith(B);
handlers
- the batch handlers that will process events.EventHandlerGroup
that can be used to set up a event processor barrier over the created event processors.public EventHandlerGroup<T> handleEventsWithWorkerPool(WorkHandler<T>... handlers)
EventProcessor
in this group has processed the event. Each event will be processed
by one of the work handler instances.
This method is generally used as part of a chain. For example if the handler A
must
process events before the worker pool with handlers B, C
:
dw.after(A).handleEventsWithWorkerPool(B, C);
handlers
- the work handlers that will process events. Each work handler instance will provide an extra thread in the worker pool.EventHandlerGroup
that can be used to set up a event processor barrier over the created event processors.public SequenceBarrier asSequenceBarrier()
BatchEventProcessor
s created by the disruptor.SequenceBarrier
including all the processors in this group.Copyright © 2018. All rights reserved.