Package 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	Description
static class	ChunkTaskPrioritySystem.SorterMessage
static class	ChunkTaskPrioritySystem.Task<T>

Field Summary

Fields

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	close()
<T> MessageListener<ChunkTaskPrioritySystem.Task<T>>	createExecutor(MessageListener<T> executor, boolean bool)
static ChunkTaskPrioritySystem.Task<Runnable>	createMessage(Runnable runnable, long pos, IntSupplier lastLevelUpdatedToProvider)
static ChunkTaskPrioritySystem.Task<Runnable>	createMessage(ChunkHolder holder, Runnable runnable)
MessageListener<ChunkTaskPrioritySystem.SorterMessage>	createSorterExecutor(MessageListener<Runnable> executor)
static ChunkTaskPrioritySystem.SorterMessage	createSorterMessage(Runnable runnable, long pos, boolean bool)
private <T> void	execute(MessageListener<T> actor, Function<MessageListener<Unit>,T> function, long long2, IntSupplier lastLevelUpdatedToProvider, boolean bool)
String	getDebugString()
private <T> LevelPrioritizedQueue<Function<MessageListener<Unit>,T>>	getQueue(MessageListener<T> actor)
private <T> void	method_17630(LevelPrioritizedQueue<Function<MessageListener<Unit>,T>> levelPrioritizedQueue, MessageListener<T> actor)
private <T> void	sort(MessageListener<T> messageListener, long long2, Runnable runnable, boolean bool)
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 Details

LOGGER

private static final Logger LOGGER

queues

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

actors

private final Set<MessageListener<?>> actors

sorter

private final TaskExecutor<TaskQueue.PrioritizedTask> sorter

Constructor Details

ChunkTaskPrioritySystem

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

Method Details

createMessage

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

createMessage

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

createSorterMessage

public static ChunkTaskPrioritySystem.SorterMessage createSorterMessage(Runnable runnable, long pos, boolean bool)

createExecutor

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

createSorterExecutor

public MessageListener<ChunkTaskPrioritySystem.SorterMessage> createSorterExecutor(MessageListener<Runnable> executor)

updateLevel

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

Specified by:

updateLevel in interface ChunkHolder.LevelUpdateListener

sort

private <T> void sort(MessageListener<T> messageListener, long long2, Runnable runnable, boolean bool)

execute

private <T> void execute(MessageListener<T> actor, Function<MessageListener<Unit>,T> function, long long2, IntSupplier lastLevelUpdatedToProvider, boolean bool)

method_17630

private <T> void method_17630(LevelPrioritizedQueue<Function<MessageListener<Unit>,T>> levelPrioritizedQueue, 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