Package com.bytedesk.core.uid.buffer

Class BufferPaddingExecutor

java.lang.Object

com.bytedesk.core.uid.buffer.BufferPaddingExecutor

public class BufferPaddingExecutor
extends Object

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

Author:

yutianbao

Field Summary

Fields

Modifier and Type	Field	Description
private final ExecutorService	bufferPadExecutors	Padding immediately by the thread pool
private final ScheduledExecutorService	bufferPadSchedule	Padding schedule thread
private static final long	DEFAULT_SCHEDULE_INTERVAL	5 minutes
private final PaddedAtomicLong	lastSecond	We can borrow UIDs from the future, here store the last second we have consumed
private static final org.slf4j.Logger	LOGGER
private final RingBuffer	ringBuffer	RingBuffer and BufferUidProvider
private final AtomicBoolean	running	Whether buffer padding is running
private static final String	SCHEDULE_NAME
private long	scheduleInterval	Schedule interval Unit as seconds
private final BufferedUidProvider	uidProvider
private static final String	WORKER_NAME	Constants

Constructor Summary

Constructors

Constructor	Description
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

Method Summary

Modifier and Type	Method	Description
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

Methods inherited from class java.lang.Object

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

Field Details

LOGGER

private static final org.slf4j.Logger LOGGER

WORKER_NAME

private static final String WORKER_NAME

Constants

See Also:

• Constant Field Values

SCHEDULE_NAME

private static final String SCHEDULE_NAME

See Also:

• Constant Field Values

DEFAULT_SCHEDULE_INTERVAL

private static final long DEFAULT_SCHEDULE_INTERVAL

5 minutes

See Also:

• Constant Field Values

running

private final AtomicBoolean running

Whether buffer padding is running

lastSecond

private final PaddedAtomicLong lastSecond

We can borrow UIDs from the future, here store the last second we have consumed

ringBuffer

private final RingBuffer ringBuffer

RingBuffer and BufferUidProvider

uidProvider

private final BufferedUidProvider uidProvider

bufferPadExecutors

private final ExecutorService bufferPadExecutors

Padding immediately by the thread pool

bufferPadSchedule

private final ScheduledExecutorService bufferPadSchedule

Padding schedule thread

scheduleInterval

private long scheduleInterval

Schedule interval Unit as seconds

Constructor Details

BufferPaddingExecutor

public BufferPaddingExecutor(RingBuffer ringBuffer,
 BufferedUidProvider uidProvider)

Constructor with RingBuffer and BufferedUidProvider, default use schedule

Parameters:

ringBuffer - RingBuffer

uidProvider - BufferedUidProvider

BufferPaddingExecutor

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

Constructor with RingBuffer, BufferedUidProvider, and whether use schedule padding

Parameters:

ringBuffer - RingBuffer

uidProvider - BufferedUidProvider

usingSchedule -

Method Details

start

public void start()

Start executors such as schedule

shutdown

public void shutdown()

Shutdown executors

isRunning

public Boolean isRunning()

Whether is padding

Returns:

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