Package net.minecraft.util.thread

Class TaskExecutor<T>

java.lang.Object
net.minecraft.util.thread.TaskExecutor<T>
All Implemented Interfaces:
AutoCloseable, Runnable, MetricSamplerSupplier, MessageListener<T>
public class TaskExecutor<T> extends Object implements MetricSamplerSupplier, MessageListener<T>, AutoCloseable, Runnable
Mappings:
Namespace Name
official aqx
intermediary net/minecraft/class_3846
named net/minecraft/util/thread/TaskExecutor

  • Field Details

    • LOGGER

      private static final Logger LOGGER
      Mappings:
      Namespace Name Mixin selector
      official a Laqx;a:Lorg/apache/logging/log4j/Logger;
      intermediary field_17040 Lnet/minecraft/class_3846;field_17040:Lorg/apache/logging/log4j/Logger;
      named LOGGER Lnet/minecraft/util/thread/TaskExecutor;LOGGER:Lorg/apache/logging/log4j/Logger;

    • field_29940

      private static final int field_29940
      See Also:
      Constant Field Values
      Mappings:
      Namespace Name Mixin selector
      official b Laqx;b:I
      intermediary field_29940 Lnet/minecraft/class_3846;field_29940:I
      named field_29940 Lnet/minecraft/util/thread/TaskExecutor;field_29940:I

    • field_29941

      private static final int field_29941
      See Also:
      Constant Field Values
      Mappings:
      Namespace Name Mixin selector
      official c Laqx;c:I
      intermediary field_29941 Lnet/minecraft/class_3846;field_29941:I
      named field_29941 Lnet/minecraft/util/thread/TaskExecutor;field_29941:I

    • stateFlags

      private final AtomicInteger stateFlags
      Mappings:
      Namespace Name Mixin selector
      official d Laqx;d:Ljava/util/concurrent/atomic/AtomicInteger;
      intermediary field_17041 Lnet/minecraft/class_3846;field_17041:Ljava/util/concurrent/atomic/AtomicInteger;
      named stateFlags Lnet/minecraft/util/thread/TaskExecutor;stateFlags:Ljava/util/concurrent/atomic/AtomicInteger;

    • queue

      private final TaskQueue<? super T,​? extends Runnable> queue
      Mappings:
      Namespace Name Mixin selector
      official e Laqx;e:Laqz;
      intermediary field_17039 Lnet/minecraft/class_3846;field_17039:Lnet/minecraft/class_3847;
      named queue Lnet/minecraft/util/thread/TaskExecutor;queue:Lnet/minecraft/util/thread/TaskQueue;

    • executor

      private final Executor executor
      Mappings:
      Namespace Name Mixin selector
      official f Laqx;f:Ljava/util/concurrent/Executor;
      intermediary field_17042 Lnet/minecraft/class_3846;field_17042:Ljava/util/concurrent/Executor;
      named executor Lnet/minecraft/util/thread/TaskExecutor;executor:Ljava/util/concurrent/Executor;

    • name

      private final String name
      Mappings:
      Namespace Name Mixin selector
      official g Laqx;g:Ljava/lang/String;
      intermediary field_17043 Lnet/minecraft/class_3846;field_17043:Ljava/lang/String;
      named name Lnet/minecraft/util/thread/TaskExecutor;name:Ljava/lang/String;

  • Constructor Details

    • TaskExecutor

      public TaskExecutor​(TaskQueue<? super T,​? extends Runnable> queue, Executor executor, String name)
      Mappings:
      Namespace Name Mixin selector
      official <init> Laqx;<init>(Laqz;Ljava/util/concurrent/Executor;Ljava/lang/String;)V
      intermediary <init> Lnet/minecraft/class_3846;<init>(Lnet/minecraft/class_3847;Ljava/util/concurrent/Executor;Ljava/lang/String;)V
      named <init> Lnet/minecraft/util/thread/TaskExecutor;<init>(Lnet/minecraft/util/thread/TaskQueue;Ljava/util/concurrent/Executor;Ljava/lang/String;)V

  • Method Details

    • create

      public static TaskExecutor<Runnable> create​(Executor executor, String name)
      Mappings:
      Namespace Name Mixin selector
      official a Laqx;a(Ljava/util/concurrent/Executor;Ljava/lang/String;)Laqx;
      intermediary method_16902 Lnet/minecraft/class_3846;method_16902(Ljava/util/concurrent/Executor;Ljava/lang/String;)Lnet/minecraft/class_3846;
      named create Lnet/minecraft/util/thread/TaskExecutor;create(Ljava/util/concurrent/Executor;Ljava/lang/String;)Lnet/minecraft/util/thread/TaskExecutor;

    • unpause

      private boolean unpause()
      Mappings:
      Namespace Name Mixin selector
      official b Laqx;b()Z
      intermediary method_16903 Lnet/minecraft/class_3846;method_16903()Z
      named unpause Lnet/minecraft/util/thread/TaskExecutor;unpause()Z

    • pause

      private void pause()
      Mappings:
      Namespace Name Mixin selector
      official c Laqx;c()V
      intermediary method_16904 Lnet/minecraft/class_3846;method_16904()V
      named pause Lnet/minecraft/util/thread/TaskExecutor;pause()V

    • hasMessages

      private boolean hasMessages()
      Mappings:
      Namespace Name Mixin selector
      official d Laqx;d()Z
      intermediary method_16905 Lnet/minecraft/class_3846;method_16905()Z
      named hasMessages Lnet/minecraft/util/thread/TaskExecutor;hasMessages()Z

    • close

      public void close()
      Specified by:
      close in interface AutoCloseable
      Specified by:
      close in interface MessageListener<T>

    • isUnpaused

      private boolean isUnpaused()
      Mappings:
      Namespace Name Mixin selector
      official e Laqx;e()Z
      intermediary method_16906 Lnet/minecraft/class_3846;method_16906()Z
      named isUnpaused Lnet/minecraft/util/thread/TaskExecutor;isUnpaused()Z

    • runNext

      private boolean runNext()
      Mappings:
      Namespace Name Mixin selector
      official f Laqx;f()Z
      intermediary method_16907 Lnet/minecraft/class_3846;method_16907()Z
      named runNext Lnet/minecraft/util/thread/TaskExecutor;runNext()Z

    • run

      public void run()
      Specified by:
      run in interface Runnable

    • send

      public void send​(T message)
      Specified by:
      send in interface MessageListener<T>
      Mappings:
      Namespace Name Mixin selector
      official a Laqw;a(Ljava/lang/Object;)V
      intermediary method_16901 Lnet/minecraft/class_3906;method_16901(Ljava/lang/Object;)V
      named send Lnet/minecraft/util/thread/MessageListener;send(Ljava/lang/Object;)V

    • execute

      private void execute()
      Mappings:
      Namespace Name Mixin selector
      official g Laqx;g()V
      intermediary method_16908 Lnet/minecraft/class_3846;method_16908()V
      named execute Lnet/minecraft/util/thread/TaskExecutor;execute()V

    • runWhile

      private int runWhile​(Int2BooleanFunction condition)
      Mappings:
      Namespace Name Mixin selector
      official a Laqx;a(Lit/unimi/dsi/fastutil/ints/Int2BooleanFunction;)I
      intermediary method_16900 Lnet/minecraft/class_3846;method_16900(Lit/unimi/dsi/fastutil/ints/Int2BooleanFunction;)I
      named runWhile Lnet/minecraft/util/thread/TaskExecutor;runWhile(Lit/unimi/dsi/fastutil/ints/Int2BooleanFunction;)I

    • getQueueSize

      public int getQueueSize()
      Mappings:
      Namespace Name Mixin selector
      official a Laqx;a()I
      intermediary method_34996 Lnet/minecraft/class_3846;method_34996()I
      named getQueueSize Lnet/minecraft/util/thread/TaskExecutor;getQueueSize()I

    • toString

      public String toString()
      Overrides:
      toString in class Object

    • getName

      public String getName()
      Specified by:
      getName in interface MessageListener<T>
      Mappings:
      Namespace Name Mixin selector
      official bo Laqw;bo()Ljava/lang/String;
      intermediary method_16898 Lnet/minecraft/class_3906;method_16898()Ljava/lang/String;
      named getName Lnet/minecraft/util/thread/MessageListener;getName()Ljava/lang/String;

    • getSamplers

      public List<SamplingRecorder> getSamplers()
      Specified by:
      getSamplers in interface MetricSamplerSupplier
      Mappings:
      Namespace Name Mixin selector
      official bl Laqc;bl()Ljava/util/List;
      intermediary method_34705 Lnet/minecraft/class_5952;method_34705()Ljava/util/List;
      named getSamplers Lnet/minecraft/util/profiler/MetricSamplerSupplier;getSamplers()Ljava/util/List;