wang.bigbird.domain.framework.id.strategy.baidu.buffer

类 BufferPaddingExecutor

java.lang.Object

wang.bigbird.domain.framework.id.strategy.baidu.buffer.BufferPaddingExecutor

public class BufferPaddingExecutor
extends Object

Represents an executor for padding RingBuffer
There are two kinds of executors: one for scheduled padding, the other for padding immediately.

作者:

yutianbao

构造器概要

构造器

构造器和说明
BufferPaddingExecutor(RingBuffer ringBuffer, BufferedUidProvider uidProvider) Constructor with RingBuffer and BufferedUidProvider, default use schedule
BufferPaddingExecutor(RingBuffer ringBuffer, BufferedUidProvider uidProvider, boolean usingSchedule) Constructor with RingBuffer, BufferedUidProvider, and whether use schedule padding

方法概要

限定符和类型	方法和说明
void	asyncPadding() Padding buffer in the thread pool
boolean	isRunning() Whether is padding
void	paddingBuffer() Padding buffer fill the slots until to catch the cursor
void	setScheduleInterval(long scheduleInterval) Setters
void	shutdown() Shutdown executors
void	start() Start executors such as schedule

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

BufferPaddingExecutor

public BufferPaddingExecutor(RingBuffer ringBuffer,
                             BufferedUidProvider uidProvider)

Constructor with RingBuffer and BufferedUidProvider, default use schedule

参数:

ringBuffer - RingBuffer

uidProvider - BufferedUidProvider

BufferPaddingExecutor

public BufferPaddingExecutor(RingBuffer ringBuffer,
                             BufferedUidProvider uidProvider,
                             boolean usingSchedule)

Constructor with RingBuffer, BufferedUidProvider, and whether use schedule padding

参数:

ringBuffer - RingBuffer

uidProvider - BufferedUidProvider

usingSchedule -

方法详细资料

start

public void start()

Start executors such as schedule

shutdown

public void shutdown()

Shutdown executors

isRunning

public boolean isRunning()

Whether is padding

返回:

asyncPadding

public void asyncPadding()

Padding buffer in the thread pool

paddingBuffer

public void paddingBuffer()

Padding buffer fill the slots until to catch the cursor

setScheduleInterval

public void setScheduleInterval(long scheduleInterval)

Setters