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)