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 ChunkHolder.LevelUpdateListener, AutoCloseable
- Mappings:
Namespace Name named net/minecraft/server/world/ChunkTaskPrioritySystem
intermediary net/minecraft/class_3900
official aqd
-
Nested Class Summary
Modifier and TypeClassDescriptionstatic final class
static final class
-
Field Summary
Modifier and TypeFieldDescriptionprivate final TaskExecutor
<TaskQueue.PrioritizedTask> private final Set
<MessageListener<?>> private static final Logger
private final Map
<MessageListener<?>, LevelPrioritizedQueue<? extends Function<MessageListener<Unit>, ?>>> -
Constructor Summary
ConstructorDescriptionChunkTaskPrioritySystem
(List<MessageListener<?>> actors, Executor executor, int maxQueues) -
Method Summary
Modifier and TypeMethodDescriptionvoid
close()
createExecutor
(MessageListener<T> executor, boolean addBlocker) static ChunkTaskPrioritySystem.Task
<Runnable> createMessage
(Runnable task, long pos, IntSupplier lastLevelUpdatedToProvider) static ChunkTaskPrioritySystem.Task
<Runnable> createMessage
(AbstractChunkHolder holder, Runnable task) static <T> ChunkTaskPrioritySystem.Task
<T> createTask
(Function<MessageListener<Unit>, T> taskFunction, long pos, IntSupplier lastLevelUpdatedToProvider) static <T> ChunkTaskPrioritySystem.Task
<T> createTask
(AbstractChunkHolder holder, Function<MessageListener<Unit>, T> taskFunction) createUnblockingExecutor
(MessageListener<Runnable> executor) 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) private <T> LevelPrioritizedQueue
<Function<MessageListener<Unit>, T>> getQueue
(MessageListener<T> actor) private <T> void
removeChunk
(MessageListener<T> actor, long chunkPos, Runnable callback, boolean clearTask) boolean
void
updateLevel
(ChunkPos pos, IntSupplier levelGetter, int targetLevel, IntConsumer levelSetter)
-
Field Details
-
LOGGER
- Mappings:
Namespace Name Mixin selector named LOGGER
Lnet/minecraft/server/world/ChunkTaskPrioritySystem;LOGGER:Lorg/slf4j/Logger;
intermediary field_17248
Lnet/minecraft/class_3900;field_17248:Lorg/slf4j/Logger;
official a
Laqd;a:Lorg/slf4j/Logger;
-
queues
private final Map<MessageListener<?>,LevelPrioritizedQueue<? extends Function<MessageListener<Unit>, queues?>>> - Mappings:
Namespace Name Mixin selector named queues
Lnet/minecraft/server/world/ChunkTaskPrioritySystem;queues:Ljava/util/Map;
intermediary field_17249
Lnet/minecraft/class_3900;field_17249:Ljava/util/Map;
official b
Laqd;b:Ljava/util/Map;
-
idleActors
- Mappings:
Namespace Name Mixin selector named idleActors
Lnet/minecraft/server/world/ChunkTaskPrioritySystem;idleActors:Ljava/util/Set;
intermediary field_17250
Lnet/minecraft/class_3900;field_17250:Ljava/util/Set;
official c
Laqd;c:Ljava/util/Set;
-
controlActor
- Mappings:
Namespace Name Mixin selector named controlActor
Lnet/minecraft/server/world/ChunkTaskPrioritySystem;controlActor:Lnet/minecraft/util/thread/TaskExecutor;
intermediary field_17251
Lnet/minecraft/class_3900;field_17251:Lnet/minecraft/class_3846;
official d
Laqd;d:Lbpj;
-
-
Constructor Details
-
ChunkTaskPrioritySystem
- Mappings:
Namespace Name Mixin selector named <init>
Lnet/minecraft/server/world/ChunkTaskPrioritySystem;<init>(Ljava/util/List;Ljava/util/concurrent/Executor;I)V
intermediary <init>
Lnet/minecraft/class_3900;<init>(Ljava/util/List;Ljava/util/concurrent/Executor;I)V
official <init>
Laqd;<init>(Ljava/util/List;Ljava/util/concurrent/Executor;I)V
-
-
Method Details
-
shouldDelayShutdown
public boolean shouldDelayShutdown()- Mappings:
Namespace Name Mixin selector named shouldDelayShutdown
Lnet/minecraft/server/world/ChunkTaskPrioritySystem;shouldDelayShutdown()Z
intermediary method_39994
Lnet/minecraft/class_3900;method_39994()Z
official a
Laqd;a()Z
-
createTask
public static <T> ChunkTaskPrioritySystem.Task<T> createTask(Function<MessageListener<Unit>, T> taskFunction, long pos, IntSupplier lastLevelUpdatedToProvider) - Mappings:
Namespace Name Mixin selector named createTask
Lnet/minecraft/server/world/ChunkTaskPrioritySystem;createTask(Ljava/util/function/Function;JLjava/util/function/IntSupplier;)Lnet/minecraft/server/world/ChunkTaskPrioritySystem$Task;
intermediary method_34871
Lnet/minecraft/class_3900;method_34871(Ljava/util/function/Function;JLjava/util/function/IntSupplier;)Lnet/minecraft/class_3900$class_3946;
official a
Laqd;a(Ljava/util/function/Function;JLjava/util/function/IntSupplier;)Laqd$a;
-
createMessage
public static ChunkTaskPrioritySystem.Task<Runnable> createMessage(Runnable task, long pos, IntSupplier lastLevelUpdatedToProvider) - Mappings:
Namespace Name Mixin selector named createMessage
Lnet/minecraft/server/world/ChunkTaskPrioritySystem;createMessage(Ljava/lang/Runnable;JLjava/util/function/IntSupplier;)Lnet/minecraft/server/world/ChunkTaskPrioritySystem$Task;
intermediary method_17626
Lnet/minecraft/class_3900;method_17626(Ljava/lang/Runnable;JLjava/util/function/IntSupplier;)Lnet/minecraft/class_3900$class_3946;
official a
Laqd;a(Ljava/lang/Runnable;JLjava/util/function/IntSupplier;)Laqd$a;
-
createMessage
public static ChunkTaskPrioritySystem.Task<Runnable> createMessage(AbstractChunkHolder holder, Runnable task) - Mappings:
Namespace Name Mixin selector named createMessage
Lnet/minecraft/server/world/ChunkTaskPrioritySystem;createMessage(Lnet/minecraft/world/chunk/AbstractChunkHolder;Ljava/lang/Runnable;)Lnet/minecraft/server/world/ChunkTaskPrioritySystem$Task;
intermediary method_17629
Lnet/minecraft/class_3900;method_17629(Lnet/minecraft/class_9761;Ljava/lang/Runnable;)Lnet/minecraft/class_3900$class_3946;
official a
Laqd;a(Laqm;Ljava/lang/Runnable;)Laqd$a;
-
createTask
public static <T> ChunkTaskPrioritySystem.Task<T> createTask(AbstractChunkHolder holder, Function<MessageListener<Unit>, T> taskFunction) - Mappings:
Namespace Name Mixin selector named createTask
Lnet/minecraft/server/world/ChunkTaskPrioritySystem;createTask(Lnet/minecraft/world/chunk/AbstractChunkHolder;Ljava/util/function/Function;)Lnet/minecraft/server/world/ChunkTaskPrioritySystem$Task;
intermediary method_34870
Lnet/minecraft/class_3900;method_34870(Lnet/minecraft/class_9761;Ljava/util/function/Function;)Lnet/minecraft/class_3900$class_3946;
official a
Laqd;a(Laqm;Ljava/util/function/Function;)Laqd$a;
-
createUnblockingMessage
public static ChunkTaskPrioritySystem.UnblockingMessage createUnblockingMessage(Runnable task, long pos, boolean removeTask) - Mappings:
Namespace Name Mixin selector named createUnblockingMessage
Lnet/minecraft/server/world/ChunkTaskPrioritySystem;createUnblockingMessage(Ljava/lang/Runnable;JZ)Lnet/minecraft/server/world/ChunkTaskPrioritySystem$UnblockingMessage;
intermediary method_17627
Lnet/minecraft/class_3900;method_17627(Ljava/lang/Runnable;JZ)Lnet/minecraft/class_3900$class_3947;
official a
Laqd;a(Ljava/lang/Runnable;JZ)Laqd$b;
-
createExecutor
public <T> MessageListener<ChunkTaskPrioritySystem.Task<T>> createExecutor(MessageListener<T> executor, boolean addBlocker) - Mappings:
Namespace Name Mixin selector named createExecutor
Lnet/minecraft/server/world/ChunkTaskPrioritySystem;createExecutor(Lnet/minecraft/util/thread/MessageListener;Z)Lnet/minecraft/util/thread/MessageListener;
intermediary method_17622
Lnet/minecraft/class_3900;method_17622(Lnet/minecraft/class_3906;Z)Lnet/minecraft/class_3906;
official a
Laqd;a(Lbpi;Z)Lbpi;
-
createUnblockingExecutor
public MessageListener<ChunkTaskPrioritySystem.UnblockingMessage> createUnblockingExecutor(MessageListener<Runnable> executor) - Mappings:
Namespace Name Mixin selector named createUnblockingExecutor
Lnet/minecraft/server/world/ChunkTaskPrioritySystem;createUnblockingExecutor(Lnet/minecraft/util/thread/MessageListener;)Lnet/minecraft/util/thread/MessageListener;
intermediary method_17614
Lnet/minecraft/class_3900;method_17614(Lnet/minecraft/class_3906;)Lnet/minecraft/class_3906;
official a
Laqd;a(Lbpi;)Lbpi;
-
updateLevel
public void updateLevel(ChunkPos pos, IntSupplier levelGetter, int targetLevel, IntConsumer levelSetter) - Specified by:
updateLevel
in interfaceChunkHolder.LevelUpdateListener
- Mappings:
Namespace Name Mixin selector named updateLevel
Lnet/minecraft/server/world/ChunkHolder$LevelUpdateListener;updateLevel(Lnet/minecraft/util/math/ChunkPos;Ljava/util/function/IntSupplier;ILjava/util/function/IntConsumer;)V
intermediary method_17209
Lnet/minecraft/class_3193$class_3896;method_17209(Lnet/minecraft/class_1923;Ljava/util/function/IntSupplier;ILjava/util/function/IntConsumer;)V
official onLevelChange
Lapy$a;onLevelChange(Ldcb;Ljava/util/function/IntSupplier;ILjava/util/function/IntConsumer;)V
-
removeChunk
private <T> void removeChunk(MessageListener<T> actor, long chunkPos, Runnable callback, boolean clearTask) - Mappings:
Namespace Name Mixin selector named removeChunk
Lnet/minecraft/server/world/ChunkTaskPrioritySystem;removeChunk(Lnet/minecraft/util/thread/MessageListener;JLjava/lang/Runnable;Z)V
intermediary method_17615
Lnet/minecraft/class_3900;method_17615(Lnet/minecraft/class_3906;JLjava/lang/Runnable;Z)V
official a
Laqd;a(Lbpi;JLjava/lang/Runnable;Z)V
-
enqueueChunk
private <T> void enqueueChunk(MessageListener<T> actor, Function<MessageListener<Unit>, T> task, long chunkPos, IntSupplier lastLevelUpdatedToProvider, boolean addBlocker) - Mappings:
Namespace Name Mixin selector named enqueueChunk
Lnet/minecraft/server/world/ChunkTaskPrioritySystem;enqueueChunk(Lnet/minecraft/util/thread/MessageListener;Ljava/util/function/Function;JLjava/util/function/IntSupplier;Z)V
intermediary method_17282
Lnet/minecraft/class_3900;method_17282(Lnet/minecraft/class_3906;Ljava/util/function/Function;JLjava/util/function/IntSupplier;Z)V
official a
Laqd;a(Lbpi;Ljava/util/function/Function;JLjava/util/function/IntSupplier;Z)V
-
enqueueExecution
private <T> void enqueueExecution(LevelPrioritizedQueue<Function<MessageListener<Unit>, T>> queue, MessageListener<T> actor) - Mappings:
Namespace Name Mixin selector named enqueueExecution
Lnet/minecraft/server/world/ChunkTaskPrioritySystem;enqueueExecution(Lnet/minecraft/server/world/LevelPrioritizedQueue;Lnet/minecraft/util/thread/MessageListener;)V
intermediary method_17630
Lnet/minecraft/class_3900;method_17630(Lnet/minecraft/class_3899;Lnet/minecraft/class_3906;)V
official a
Laqd;a(Laqc;Lbpi;)V
-
getQueue
private <T> LevelPrioritizedQueue<Function<MessageListener<Unit>,T>> getQueue(MessageListener<T> actor) - Mappings:
Namespace Name Mixin selector named getQueue
Lnet/minecraft/server/world/ChunkTaskPrioritySystem;getQueue(Lnet/minecraft/util/thread/MessageListener;)Lnet/minecraft/server/world/LevelPrioritizedQueue;
intermediary method_17632
Lnet/minecraft/class_3900;method_17632(Lnet/minecraft/class_3906;)Lnet/minecraft/class_3899;
official b
Laqd;b(Lbpi;)Laqc;
-
getDebugString
- Mappings:
Namespace Name Mixin selector named getDebugString
Lnet/minecraft/server/world/ChunkTaskPrioritySystem;getDebugString()Ljava/lang/String;
intermediary method_21680
Lnet/minecraft/class_3900;method_21680()Ljava/lang/String;
official b
Laqd;b()Ljava/lang/String;
-
close
public void close()- Specified by:
close
in interfaceAutoCloseable
-