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 official afv
intermediary net/minecraft/class_3900
named net/minecraft/server/world/ChunkTaskPrioritySystem
-
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
(ChunkHolder holder, Runnable task) static <T> ChunkTaskPrioritySystem.Task<T>
createTask
(Function<MessageListener<Unit>, T> taskFunction, long pos, IntSupplier lastLevelUpdatedToProvider) static <T> ChunkTaskPrioritySystem.Task<T>
createTask
(ChunkHolder 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 official a
Lafv;a:Lorg/slf4j/Logger;
intermediary field_17248
Lnet/minecraft/class_3900;field_17248:Lorg/slf4j/Logger;
named LOGGER
Lnet/minecraft/server/world/ChunkTaskPrioritySystem;LOGGER:Lorg/slf4j/Logger;
-
queues
private final Map<MessageListener<?>,LevelPrioritizedQueue<? extends Function<MessageListener<Unit>, queues?>>> - Mappings:
Namespace Name Mixin selector official b
Lafv;b:Ljava/util/Map;
intermediary field_17249
Lnet/minecraft/class_3900;field_17249:Ljava/util/Map;
named queues
Lnet/minecraft/server/world/ChunkTaskPrioritySystem;queues:Ljava/util/Map;
-
idleActors
- Mappings:
Namespace Name Mixin selector official c
Lafv;c:Ljava/util/Set;
intermediary field_17250
Lnet/minecraft/class_3900;field_17250:Ljava/util/Set;
named idleActors
Lnet/minecraft/server/world/ChunkTaskPrioritySystem;idleActors:Ljava/util/Set;
-
controlActor
- Mappings:
Namespace Name Mixin selector official d
Lafv;d:Lazc;
intermediary field_17251
Lnet/minecraft/class_3900;field_17251:Lnet/minecraft/class_3846;
named controlActor
Lnet/minecraft/server/world/ChunkTaskPrioritySystem;controlActor:Lnet/minecraft/util/thread/TaskExecutor;
-
-
Constructor Details
-
ChunkTaskPrioritySystem
- Mappings:
Namespace Name Mixin selector official <init>
Lafv;<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
named <init>
Lnet/minecraft/server/world/ChunkTaskPrioritySystem;<init>(Ljava/util/List;Ljava/util/concurrent/Executor;I)V
-
-
Method Details
-
shouldDelayShutdown
public boolean shouldDelayShutdown()- Mappings:
Namespace Name Mixin selector official a
Lafv;a()Z
intermediary method_39994
Lnet/minecraft/class_3900;method_39994()Z
named shouldDelayShutdown
Lnet/minecraft/server/world/ChunkTaskPrioritySystem;shouldDelayShutdown()Z
-
createTask
public static <T> ChunkTaskPrioritySystem.Task<T> createTask(Function<MessageListener<Unit>, T> taskFunction, long pos, IntSupplier lastLevelUpdatedToProvider) - Mappings:
Namespace Name Mixin selector official a
Lafv;a(Ljava/util/function/Function;JLjava/util/function/IntSupplier;)Lafv$a;
intermediary method_34871
Lnet/minecraft/class_3900;method_34871(Ljava/util/function/Function;JLjava/util/function/IntSupplier;)Lnet/minecraft/class_3900$class_3946;
named createTask
Lnet/minecraft/server/world/ChunkTaskPrioritySystem;createTask(Ljava/util/function/Function;JLjava/util/function/IntSupplier;)Lnet/minecraft/server/world/ChunkTaskPrioritySystem$Task;
-
createMessage
public static ChunkTaskPrioritySystem.Task<Runnable> createMessage(Runnable task, long pos, IntSupplier lastLevelUpdatedToProvider) - Mappings:
Namespace Name Mixin selector official a
Lafv;a(Ljava/lang/Runnable;JLjava/util/function/IntSupplier;)Lafv$a;
intermediary method_17626
Lnet/minecraft/class_3900;method_17626(Ljava/lang/Runnable;JLjava/util/function/IntSupplier;)Lnet/minecraft/class_3900$class_3946;
named createMessage
Lnet/minecraft/server/world/ChunkTaskPrioritySystem;createMessage(Ljava/lang/Runnable;JLjava/util/function/IntSupplier;)Lnet/minecraft/server/world/ChunkTaskPrioritySystem$Task;
-
createMessage
public static ChunkTaskPrioritySystem.Task<Runnable> createMessage(ChunkHolder holder, Runnable task) - Mappings:
Namespace Name Mixin selector official a
Lafv;a(Lafs;Ljava/lang/Runnable;)Lafv$a;
intermediary method_17629
Lnet/minecraft/class_3900;method_17629(Lnet/minecraft/class_3193;Ljava/lang/Runnable;)Lnet/minecraft/class_3900$class_3946;
named createMessage
Lnet/minecraft/server/world/ChunkTaskPrioritySystem;createMessage(Lnet/minecraft/server/world/ChunkHolder;Ljava/lang/Runnable;)Lnet/minecraft/server/world/ChunkTaskPrioritySystem$Task;
-
createTask
public static <T> ChunkTaskPrioritySystem.Task<T> createTask(ChunkHolder holder, Function<MessageListener<Unit>, T> taskFunction) - Mappings:
Namespace Name Mixin selector official a
Lafv;a(Lafs;Ljava/util/function/Function;)Lafv$a;
intermediary method_34870
Lnet/minecraft/class_3900;method_34870(Lnet/minecraft/class_3193;Ljava/util/function/Function;)Lnet/minecraft/class_3900$class_3946;
named createTask
Lnet/minecraft/server/world/ChunkTaskPrioritySystem;createTask(Lnet/minecraft/server/world/ChunkHolder;Ljava/util/function/Function;)Lnet/minecraft/server/world/ChunkTaskPrioritySystem$Task;
-
createUnblockingMessage
public static ChunkTaskPrioritySystem.UnblockingMessage createUnblockingMessage(Runnable task, long pos, boolean removeTask) - Mappings:
Namespace Name Mixin selector official a
Lafv;a(Ljava/lang/Runnable;JZ)Lafv$b;
intermediary method_17627
Lnet/minecraft/class_3900;method_17627(Ljava/lang/Runnable;JZ)Lnet/minecraft/class_3900$class_3947;
named createUnblockingMessage
Lnet/minecraft/server/world/ChunkTaskPrioritySystem;createUnblockingMessage(Ljava/lang/Runnable;JZ)Lnet/minecraft/server/world/ChunkTaskPrioritySystem$UnblockingMessage;
-
createExecutor
public <T> MessageListener<ChunkTaskPrioritySystem.Task<T>> createExecutor(MessageListener<T> executor, boolean addBlocker) - Mappings:
Namespace Name Mixin selector official a
Lafv;a(Lazb;Z)Lazb;
intermediary method_17622
Lnet/minecraft/class_3900;method_17622(Lnet/minecraft/class_3906;Z)Lnet/minecraft/class_3906;
named createExecutor
Lnet/minecraft/server/world/ChunkTaskPrioritySystem;createExecutor(Lnet/minecraft/util/thread/MessageListener;Z)Lnet/minecraft/util/thread/MessageListener;
-
createUnblockingExecutor
public MessageListener<ChunkTaskPrioritySystem.UnblockingMessage> createUnblockingExecutor(MessageListener<Runnable> executor) - Mappings:
Namespace Name Mixin selector official a
Lafv;a(Lazb;)Lazb;
intermediary method_17614
Lnet/minecraft/class_3900;method_17614(Lnet/minecraft/class_3906;)Lnet/minecraft/class_3906;
named createUnblockingExecutor
Lnet/minecraft/server/world/ChunkTaskPrioritySystem;createUnblockingExecutor(Lnet/minecraft/util/thread/MessageListener;)Lnet/minecraft/util/thread/MessageListener;
-
updateLevel
public void updateLevel(ChunkPos pos, IntSupplier levelGetter, int targetLevel, IntConsumer levelSetter) - Specified by:
updateLevel
in interfaceChunkHolder.LevelUpdateListener
- Mappings:
Namespace Name Mixin selector official onLevelChange
Lafs$d;onLevelChange(Lcge;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
named updateLevel
Lnet/minecraft/server/world/ChunkHolder$LevelUpdateListener;updateLevel(Lnet/minecraft/util/math/ChunkPos;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 official a
Lafv;a(Lazb;JLjava/lang/Runnable;Z)V
intermediary method_17615
Lnet/minecraft/class_3900;method_17615(Lnet/minecraft/class_3906;JLjava/lang/Runnable;Z)V
named removeChunk
Lnet/minecraft/server/world/ChunkTaskPrioritySystem;removeChunk(Lnet/minecraft/util/thread/MessageListener;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 official a
Lafv;a(Lazb;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
named enqueueChunk
Lnet/minecraft/server/world/ChunkTaskPrioritySystem;enqueueChunk(Lnet/minecraft/util/thread/MessageListener;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 official a
Lafv;a(Lafu;Lazb;)V
intermediary method_17630
Lnet/minecraft/class_3900;method_17630(Lnet/minecraft/class_3899;Lnet/minecraft/class_3906;)V
named enqueueExecution
Lnet/minecraft/server/world/ChunkTaskPrioritySystem;enqueueExecution(Lnet/minecraft/server/world/LevelPrioritizedQueue;Lnet/minecraft/util/thread/MessageListener;)V
-
getQueue
private <T> LevelPrioritizedQueue<Function<MessageListener<Unit>,T>> getQueue(MessageListener<T> actor) - Mappings:
Namespace Name Mixin selector official b
Lafv;b(Lazb;)Lafu;
intermediary method_17632
Lnet/minecraft/class_3900;method_17632(Lnet/minecraft/class_3906;)Lnet/minecraft/class_3899;
named getQueue
Lnet/minecraft/server/world/ChunkTaskPrioritySystem;getQueue(Lnet/minecraft/util/thread/MessageListener;)Lnet/minecraft/server/world/LevelPrioritizedQueue;
-
getDebugString
- Mappings:
Namespace Name Mixin selector official b
Lafv;b()Ljava/lang/String;
intermediary method_21680
Lnet/minecraft/class_3900;method_21680()Ljava/lang/String;
named getDebugString
Lnet/minecraft/server/world/ChunkTaskPrioritySystem;getDebugString()Ljava/lang/String;
-
close
public void close()- Specified by:
close
in interfaceAutoCloseable
-