public class BufferedIncrementRunnable
extends Object
implements Runnable
Constructor and Description |
---|
BufferedIncrementRunnable(BufferedIncrementConfiguration bufferedIncrementConfiguration,
BatchablePipe<Serializable,com.liferay.portal.kernel.increment.Increment<?>> batchablePipe,
AtomicInteger queueLengthTracker,
Thread dispatchThread) |
Modifier and Type | Method and Description |
---|---|
void |
run() |
public BufferedIncrementRunnable(BufferedIncrementConfiguration bufferedIncrementConfiguration, BatchablePipe<Serializable,com.liferay.portal.kernel.increment.Increment<?>> batchablePipe, AtomicInteger queueLengthTracker, Thread dispatchThread)