Class ThrottlingChunkTaskDispatcher

java.lang.Object

net.minecraft.server.level.ChunkTaskDispatcher

net.minecraft.server.level.ThrottlingChunkTaskDispatcher

All Implemented Interfaces:

AutoCloseable, ChunkHolder.LevelChangeListener

public class ThrottlingChunkTaskDispatcher
extends ChunkTaskDispatcher

Field Summary

Fields

Modifier and Type	Field	Description
private final it.unimi.dsi.fastutil.longs.LongSet	chunkPositionsInExecution
private final String	executorSchedulerName
private final int	maxChunksInExecution

Fields inherited from class ChunkTaskDispatcher

DISPATCHER_PRIORITY_COUNT, sleeping

Constructor Summary

Constructors

Constructor	Description
ThrottlingChunkTaskDispatcher(TaskScheduler<Runnable> executor, Executor dispatcherExecutor, int maxChunksInExecution)

Method Summary

Modifier and Type	Method	Description
String	getDebugStatus()
protected void	onRelease(long key)
protected @Nullable ChunkTaskPriorityQueue.TasksForChunk	popTasks()
protected void	scheduleForExecution(ChunkTaskPriorityQueue.TasksForChunk tasksForChunk)

Methods inherited from class ChunkTaskDispatcher

close, hasWork, onLevelChange, pollTask, release, submit

Methods inherited from class Object

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

Field Details

chunkPositionsInExecution

private final it.unimi.dsi.fastutil.longs.LongSet chunkPositionsInExecution

maxChunksInExecution

private final int maxChunksInExecution

executorSchedulerName

private final String executorSchedulerName

Constructor Details

ThrottlingChunkTaskDispatcher

public ThrottlingChunkTaskDispatcher(TaskScheduler<Runnable> executor,
 Executor dispatcherExecutor,
 int maxChunksInExecution)

Method Details

onRelease

protected void onRelease(long key)

Overrides:

onRelease in class ChunkTaskDispatcher

popTasks

protected @Nullable ChunkTaskPriorityQueue.TasksForChunk popTasks()

Overrides:

popTasks in class ChunkTaskDispatcher

scheduleForExecution

protected void scheduleForExecution(ChunkTaskPriorityQueue.TasksForChunk tasksForChunk)

Overrides:

scheduleForExecution in class ChunkTaskDispatcher

getDebugStatus

public String getDebugStatus()