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:Lbcq;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(Lbcp;Z)Lbcp;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(Lbcp;)Lbcp;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(Lclt;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(Lbcp;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(Lbcp;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;Lbcp;)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(Lbcp;)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
 
 -