Package net.minecraft.server.level

Class ChunkTaskDispatcher

java.lang.Object

net.minecraft.server.level.ChunkTaskDispatcher

All Implemented Interfaces:

AutoCloseable, ChunkHolder.LevelChangeListener

Direct Known Subclasses:

ThrottlingChunkTaskDispatcher

public class ChunkTaskDispatcher
extends Object
implements ChunkHolder.LevelChangeListener, AutoCloseable

Field Summary

Fields

Modifier and Type	Field	Description
private final PriorityConsecutiveExecutor	dispatcher
static final int	DISPATCHER_PRIORITY_COUNT
private final TaskScheduler<Runnable>	executor
private static final org.slf4j.Logger	LOGGER
private final ChunkTaskPriorityQueue	queue
protected boolean	sleeping

Constructor Summary

Constructors

Constructor	Description
ChunkTaskDispatcher(TaskScheduler<Runnable> pExecutor, Executor pDispatcher)

Method Summary

Modifier and Type	Method	Description
void	close()
boolean	hasWork()
void	onLevelChange(ChunkPos pChunkPos, IntSupplier pQueueLevelGetter, int pTicketLevel, IntConsumer pQueueLevelSetter)
protected void	onRelease(long pChunkPos)
protected void	pollTask()
protected ChunkTaskPriorityQueue.TasksForChunk	popTasks()
void	release(long pChunkPos, Runnable pAfterRelease, boolean pFullClear)
protected void	scheduleForExecution(ChunkTaskPriorityQueue.TasksForChunk pTasks)
void	submit(Runnable pTask, long pChunkPos, IntSupplier pQueueLevelSupplier)

Methods inherited from class java.lang.Object

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

Field Details

DISPATCHER_PRIORITY_COUNT

public static final int DISPATCHER_PRIORITY_COUNT

See Also:

• Constant Field Values

LOGGER

private static final org.slf4j.Logger LOGGER

queue

private final ChunkTaskPriorityQueue queue

executor

private final TaskScheduler<Runnable> executor

dispatcher

private final PriorityConsecutiveExecutor dispatcher

sleeping

protected boolean sleeping

Constructor Details

ChunkTaskDispatcher

public ChunkTaskDispatcher(TaskScheduler<Runnable> pExecutor,
 Executor pDispatcher)

Method Details

hasWork

public boolean hasWork()

onLevelChange

public void onLevelChange(ChunkPos pChunkPos,
 IntSupplier pQueueLevelGetter,
 int pTicketLevel,
 IntConsumer pQueueLevelSetter)

Specified by:

onLevelChange in interface ChunkHolder.LevelChangeListener

release

public void release(long pChunkPos,
 Runnable pAfterRelease,
 boolean pFullClear)

submit

public void submit(Runnable pTask,
 long pChunkPos,
 IntSupplier pQueueLevelSupplier)

pollTask

protected void pollTask()

scheduleForExecution

protected void scheduleForExecution(ChunkTaskPriorityQueue.TasksForChunk pTasks)

onRelease

protected void onRelease(long pChunkPos)

popTasks

@Nullable
protected ChunkTaskPriorityQueue.TasksForChunk popTasks()

close

public void close()

Specified by:

close in interface AutoCloseable