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> p_371624_, Executor p_371524_)

Method Summary

Modifier and Type	Method	Description
void	close()
boolean	hasWork()
void	onLevelChange(ChunkPos p_371270_, IntSupplier p_371804_, int p_371325_, IntConsumer p_371889_)
protected void	onRelease(long p_371807_)
protected void	pollTask()
protected ChunkTaskPriorityQueue.TasksForChunk	popTasks()
void	release(long p_371596_, Runnable p_371195_, boolean p_371837_)
protected void	scheduleForExecution(ChunkTaskPriorityQueue.TasksForChunk p_371732_)
void	submit(Runnable p_371654_, long p_371885_, IntSupplier p_371509_)

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> p_371624_,
 Executor p_371524_)

Method Details

hasWork

public boolean hasWork()

onLevelChange

public void onLevelChange(ChunkPos p_371270_,
 IntSupplier p_371804_,
 int p_371325_,
 IntConsumer p_371889_)

Specified by:

onLevelChange in interface ChunkHolder.LevelChangeListener

release

public void release(long p_371596_,
 Runnable p_371195_,
 boolean p_371837_)

submit

public void submit(Runnable p_371654_,
 long p_371885_,
 IntSupplier p_371509_)

pollTask

protected void pollTask()

scheduleForExecution

protected void scheduleForExecution(ChunkTaskPriorityQueue.TasksForChunk p_371732_)

onRelease

protected void onRelease(long p_371807_)

popTasks

@Nullable
protected ChunkTaskPriorityQueue.TasksForChunk popTasks()

close

public void close()

Specified by:

close in interface AutoCloseable