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 abg
intermediary net/minecraft/class_3900
named net/minecraft/server/world/ChunkTaskPrioritySystem
-
Nested Class Summary
Modifier and TypeClassDescriptionstatic class
static class
-
Field Summary
Modifier and TypeFieldDescriptionprivate TaskExecutor<TaskQueue.PrioritizedTask>
private Set<MessageListener<?>>
private static Logger
private 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)
void
updateLevel(ChunkPos pos, IntSupplier levelGetter, int targetLevel, IntConsumer levelSetter)
-
Field Details
-
LOGGER
- Mappings:
Namespace Name Mixin selector official a
Labg;a:Lorg/apache/logging/log4j/Logger;
intermediary field_17248
Lnet/minecraft/class_3900;field_17248:Lorg/apache/logging/log4j/Logger;
named LOGGER
Lnet/minecraft/server/world/ChunkTaskPrioritySystem;LOGGER:Lorg/apache/logging/log4j/Logger;
-
queues
private final Map<MessageListener<?>,LevelPrioritizedQueue<? extends Function<MessageListener<Unit>,?>>> queues- Mappings:
Namespace Name Mixin selector official b
Labg;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
Labg;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
Labg;d:Laqx;
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>
Labg;<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
-
createTask
public static <T> ChunkTaskPrioritySystem.Task<T> createTask(Function<MessageListener<Unit>,T> taskFunction, long pos, IntSupplier lastLevelUpdatedToProvider)- Mappings:
Namespace Name Mixin selector official a
Labg;a(Ljava/util/function/Function;JLjava/util/function/IntSupplier;)Labg$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
Labg;a(Ljava/lang/Runnable;JLjava/util/function/IntSupplier;)Labg$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
Labg;a(Labd;Ljava/lang/Runnable;)Labg$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
Labg;a(Labd;Ljava/util/function/Function;)Labg$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
Labg;a(Ljava/lang/Runnable;JZ)Labg$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
Labg;a(Laqw;Z)Laqw;
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
Labg;a(Laqw;)Laqw;
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 a
Labd$d;a(Lbvu;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
Labg;a(Laqw;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
Labg;a(Laqw;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
Labg;a(Labf;Laqw;)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
Labg;b(Laqw;)Labf;
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 a
Labg;a()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
-