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 ahtintermediary net/minecraft/class_3900named net/minecraft/server/world/ChunkTaskPrioritySystem
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionstatic final classstatic final class -
Field Summary
FieldsModifier and TypeFieldDescriptionprivate final TaskExecutor<TaskQueue.PrioritizedTask>private final Set<MessageListener<?>>private static final Loggerprivate final Map<MessageListener<?>,LevelPrioritizedQueue<? extends Function<MessageListener<Unit>, ?>>> -
Constructor Summary
ConstructorsConstructorDescriptionChunkTaskPrioritySystem(List<MessageListener<?>> actors, Executor executor, int maxQueues) -
Method Summary
Modifier and TypeMethodDescriptionvoidclose()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> voidenqueueChunk(MessageListener<T> actor, Function<MessageListener<Unit>, T> task, long chunkPos, IntSupplier lastLevelUpdatedToProvider, boolean addBlocker) private <T> voidenqueueExecution(LevelPrioritizedQueue<Function<MessageListener<Unit>, T>> queue, MessageListener<T> actor) private <T> LevelPrioritizedQueue<Function<MessageListener<Unit>,T>> getQueue(MessageListener<T> actor) private <T> voidremoveChunk(MessageListener<T> actor, long chunkPos, Runnable callback, boolean clearTask) booleanvoidupdateLevel(ChunkPos pos, IntSupplier levelGetter, int targetLevel, IntConsumer levelSetter)
-
Field Details
-
LOGGER
- Mappings:
Namespace Name Mixin selector official aLaht;a:Lorg/slf4j/Logger;intermediary field_17248Lnet/minecraft/class_3900;field_17248:Lorg/slf4j/Logger;named LOGGERLnet/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 bLaht;b:Ljava/util/Map;intermediary field_17249Lnet/minecraft/class_3900;field_17249:Ljava/util/Map;named queuesLnet/minecraft/server/world/ChunkTaskPrioritySystem;queues:Ljava/util/Map;
-
idleActors
- Mappings:
Namespace Name Mixin selector official cLaht;c:Ljava/util/Set;intermediary field_17250Lnet/minecraft/class_3900;field_17250:Ljava/util/Set;named idleActorsLnet/minecraft/server/world/ChunkTaskPrioritySystem;idleActors:Ljava/util/Set;
-
controlActor
- Mappings:
Namespace Name Mixin selector official dLaht;d:Lbcp;intermediary field_17251Lnet/minecraft/class_3900;field_17251:Lnet/minecraft/class_3846;named controlActorLnet/minecraft/server/world/ChunkTaskPrioritySystem;controlActor:Lnet/minecraft/util/thread/TaskExecutor;
-
-
Constructor Details
-
ChunkTaskPrioritySystem
- Mappings:
Namespace Name Mixin selector official <init>Laht;<init>(Ljava/util/List;Ljava/util/concurrent/Executor;I)Vintermediary <init>Lnet/minecraft/class_3900;<init>(Ljava/util/List;Ljava/util/concurrent/Executor;I)Vnamed <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 aLaht;a()Zintermediary method_39994Lnet/minecraft/class_3900;method_39994()Znamed shouldDelayShutdownLnet/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 aLaht;a(Ljava/util/function/Function;JLjava/util/function/IntSupplier;)Laht$a;intermediary method_34871Lnet/minecraft/class_3900;method_34871(Ljava/util/function/Function;JLjava/util/function/IntSupplier;)Lnet/minecraft/class_3900$class_3946;named createTaskLnet/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 aLaht;a(Ljava/lang/Runnable;JLjava/util/function/IntSupplier;)Laht$a;intermediary method_17626Lnet/minecraft/class_3900;method_17626(Ljava/lang/Runnable;JLjava/util/function/IntSupplier;)Lnet/minecraft/class_3900$class_3946;named createMessageLnet/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 aLaht;a(Lahp;Ljava/lang/Runnable;)Laht$a;intermediary method_17629Lnet/minecraft/class_3900;method_17629(Lnet/minecraft/class_3193;Ljava/lang/Runnable;)Lnet/minecraft/class_3900$class_3946;named createMessageLnet/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 aLaht;a(Lahp;Ljava/util/function/Function;)Laht$a;intermediary method_34870Lnet/minecraft/class_3900;method_34870(Lnet/minecraft/class_3193;Ljava/util/function/Function;)Lnet/minecraft/class_3900$class_3946;named createTaskLnet/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 aLaht;a(Ljava/lang/Runnable;JZ)Laht$b;intermediary method_17627Lnet/minecraft/class_3900;method_17627(Ljava/lang/Runnable;JZ)Lnet/minecraft/class_3900$class_3947;named createUnblockingMessageLnet/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 aLaht;a(Lbco;Z)Lbco;intermediary method_17622Lnet/minecraft/class_3900;method_17622(Lnet/minecraft/class_3906;Z)Lnet/minecraft/class_3906;named createExecutorLnet/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 aLaht;a(Lbco;)Lbco;intermediary method_17614Lnet/minecraft/class_3900;method_17614(Lnet/minecraft/class_3906;)Lnet/minecraft/class_3906;named createUnblockingExecutorLnet/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:
updateLevelin interfaceChunkHolder.LevelUpdateListener- Mappings:
Namespace Name Mixin selector official onLevelChangeLahp$c;onLevelChange(Lclr;Ljava/util/function/IntSupplier;ILjava/util/function/IntConsumer;)Vintermediary method_17209Lnet/minecraft/class_3193$class_3896;method_17209(Lnet/minecraft/class_1923;Ljava/util/function/IntSupplier;ILjava/util/function/IntConsumer;)Vnamed updateLevelLnet/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 aLaht;a(Lbco;JLjava/lang/Runnable;Z)Vintermediary method_17615Lnet/minecraft/class_3900;method_17615(Lnet/minecraft/class_3906;JLjava/lang/Runnable;Z)Vnamed removeChunkLnet/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 aLaht;a(Lbco;Ljava/util/function/Function;JLjava/util/function/IntSupplier;Z)Vintermediary method_17282Lnet/minecraft/class_3900;method_17282(Lnet/minecraft/class_3906;Ljava/util/function/Function;JLjava/util/function/IntSupplier;Z)Vnamed enqueueChunkLnet/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 aLaht;a(Lahs;Lbco;)Vintermediary method_17630Lnet/minecraft/class_3900;method_17630(Lnet/minecraft/class_3899;Lnet/minecraft/class_3906;)Vnamed enqueueExecutionLnet/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 bLaht;b(Lbco;)Lahs;intermediary method_17632Lnet/minecraft/class_3900;method_17632(Lnet/minecraft/class_3906;)Lnet/minecraft/class_3899;named getQueueLnet/minecraft/server/world/ChunkTaskPrioritySystem;getQueue(Lnet/minecraft/util/thread/MessageListener;)Lnet/minecraft/server/world/LevelPrioritizedQueue;
-
getDebugString
- Mappings:
Namespace Name Mixin selector official bLaht;b()Ljava/lang/String;intermediary method_21680Lnet/minecraft/class_3900;method_21680()Ljava/lang/String;named getDebugStringLnet/minecraft/server/world/ChunkTaskPrioritySystem;getDebugString()Ljava/lang/String;
-
close
public void close()- Specified by:
closein interfaceAutoCloseable
-