/*
 * Copyright 2011 LMAX Ltd.
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 * http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
package com.lmax.disruptor;

Callback interface to be implemented for processing units of work as they become available in the RingBuffer.
Type parameters:
  • <T> – event implementation storing the data for sharing during exchange or parallel coordination of an event.
See Also:
/** * Callback interface to be implemented for processing units of work as they become available in the {@link RingBuffer}. * * @param <T> event implementation storing the data for sharing during exchange or parallel coordination of an event. * @see WorkerPool */
public interface WorkHandler<T> {
Callback to indicate a unit of work needs to be processed.
Params:
Throws:
/** * Callback to indicate a unit of work needs to be processed. * * @param event published to the {@link RingBuffer} * @throws Exception if the {@link WorkHandler} would like the exception handled further up the chain. */
void onEvent(T event) throws Exception; }