net.minecraft.server.world

Class ChunkTaskPrioritySystem

java.lang.Object

net.minecraft.server.world.ChunkTaskPrioritySystem

All Implemented Interfaces:

AutoCloseable, ChunkHolder.LevelUpdateListener

public class ChunkTaskPrioritySystem
extends Object
implements AutoCloseable, ChunkHolder.LevelUpdateListener

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ChunkTaskPrioritySystem.Task<T>
static class	ChunkTaskPrioritySystem.UnblockingMessage

Field Summary

Fields

Modifier and Type	Field and Description
private TaskExecutor<TaskQueue.PrioritizedTask>	controlActor
private Set<MessageListener<?>>	idleActors
private static Logger	LOGGER
private Map<MessageListener<?>,LevelPrioritizedQueue<? extends Function<MessageListener<Unit>,?>>>	queues

Constructor Summary

Constructors

Constructor and Description
ChunkTaskPrioritySystem(List<MessageListener<?>> actors, Executor executor, int maxQueues)

Method Summary

Modifier and Type	Method and Description
void	close()
<T> MessageListener<ChunkTaskPrioritySystem.Task<T>>	createExecutor(MessageListener<T> executor, boolean addBlocker)
static ChunkTaskPrioritySystem.Task<Runnable>	createMessage(ChunkHolder holder, Runnable task)
static ChunkTaskPrioritySystem.Task<Runnable>	createMessage(Runnable task, long pos, IntSupplier lastLevelUpdatedToProvider)
MessageListener<ChunkTaskPrioritySystem.UnblockingMessage>	createUnblockingExecutor(MessageListener<Runnable> executor)
static ChunkTaskPrioritySystem.UnblockingMessage	createUnblockingMessage(Runnable task, long pos, boolean removeTask)
private <T> void	enqueueChunk(MessageListener<T> actor, Function<MessageListener<Unit>,T> task, long chunkPos, IntSupplier lastLevelUpdatedToProvider, boolean addBlocker)
private <T> void	enqueueExecution(LevelPrioritizedQueue<Function<MessageListener<Unit>,T>> queue, MessageListener<T> actor)
String	getDebugString()
private <T> LevelPrioritizedQueue<Function<MessageListener<Unit>,T>>	getQueue(MessageListener<T> actor)
private <T> void	removeChunk(MessageListener<T> actor, long chunkPos, Runnable callback, boolean clearTask)
void	updateLevel(ChunkPos pos, IntSupplier levelGetter, int targetLevel, IntConsumer levelSetter)

Methods inherited from class java.lang.Object

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

Field Detail

LOGGER

private static final Logger LOGGER

queues

private final Map<MessageListener<?>,LevelPrioritizedQueue<? extends Function<MessageListener<Unit>,?>>> queues

idleActors

private final Set<MessageListener<?>> idleActors

controlActor

private final TaskExecutor<TaskQueue.PrioritizedTask> controlActor

Constructor Detail

ChunkTaskPrioritySystem

public ChunkTaskPrioritySystem(List<MessageListener<?>> actors,
                               Executor executor,
                               int maxQueues)

Method Detail

createMessage

public static ChunkTaskPrioritySystem.Task<Runnable> createMessage(Runnable task,
                                                                   long pos,
                                                                   IntSupplier lastLevelUpdatedToProvider)

createMessage

public static ChunkTaskPrioritySystem.Task<Runnable> createMessage(ChunkHolder holder,
                                                                   Runnable task)

createUnblockingMessage

public static ChunkTaskPrioritySystem.UnblockingMessage createUnblockingMessage(Runnable task,
                                                                                long pos,
                                                                                boolean removeTask)

createExecutor

public <T> MessageListener<ChunkTaskPrioritySystem.Task<T>> createExecutor(MessageListener<T> executor,
                                                                           boolean addBlocker)

createUnblockingExecutor

public MessageListener<ChunkTaskPrioritySystem.UnblockingMessage> createUnblockingExecutor(MessageListener<Runnable> executor)

updateLevel

public void updateLevel(ChunkPos pos,
                        IntSupplier levelGetter,
                        int targetLevel,
                        IntConsumer levelSetter)

Specified by:

updateLevel in interface ChunkHolder.LevelUpdateListener

removeChunk

private <T> void removeChunk(MessageListener<T> actor,
                             long chunkPos,
                             Runnable callback,
                             boolean clearTask)

enqueueChunk

private <T> void enqueueChunk(MessageListener<T> actor,
                              Function<MessageListener<Unit>,T> task,
                              long chunkPos,
                              IntSupplier lastLevelUpdatedToProvider,
                              boolean addBlocker)

enqueueExecution

private <T> void enqueueExecution(LevelPrioritizedQueue<Function<MessageListener<Unit>,T>> queue,
                                  MessageListener<T> actor)

getQueue

private <T> LevelPrioritizedQueue<Function<MessageListener<Unit>,T>> getQueue(MessageListener<T> actor)

getDebugString

public String getDebugString()

close

public void close()

Specified by:

close in interface AutoCloseable