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 aqe

  • Field Details

    • LOGGER

      private static final Logger 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 Laqe;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 Laqe;b:Ljava/util/Map;

    • idleActors

      private final Set<MessageListener<?>> 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 Laqe;c:Ljava/util/Set;

    • controlActor

      private final TaskExecutor<TaskQueue.PrioritizedTask> 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 Laqe;d:Lbpk;

  • Constructor Details

    • ChunkTaskPrioritySystem

      public ChunkTaskPrioritySystem(List<MessageListener<?>> actors, Executor executor, int maxQueues)
      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> Laqe;<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 Laqe;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 Laqe;a(Ljava/util/function/Function;JLjava/util/function/IntSupplier;)Laqe$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 Laqe;a(Ljava/lang/Runnable;JLjava/util/function/IntSupplier;)Laqe$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 Laqe;a(Laqn;Ljava/lang/Runnable;)Laqe$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 Laqe;a(Laqn;Ljava/util/function/Function;)Laqe$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 Laqe;a(Ljava/lang/Runnable;JZ)Laqe$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 Laqe;a(Lbpj;Z)Lbpj;

    • 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 Laqe;a(Lbpj;)Lbpj;

    • updateLevel

      public void updateLevel(ChunkPos pos, IntSupplier levelGetter, int targetLevel, IntConsumer levelSetter)
      Specified by:
      updateLevel in interface ChunkHolder.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 Lapz$a;onLevelChange(Ldcd;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 Laqe;a(Lbpj;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 Laqe;a(Lbpj;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 Laqe;a(Laqd;Lbpj;)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 Laqe;b(Lbpj;)Laqd;

    • getDebugString

      public String 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 Laqe;b()Ljava/lang/String;

    • close

      public void close()
      Specified by:
      close in interface AutoCloseable