Class TaskExecutor<T>

java.lang.Object
net.minecraft.util.thread.TaskExecutor<T>
All Implemented Interfaces:
AutoCloseable, Runnable, MessageListener<T>, SampleableExecutor

public class TaskExecutor<T> extends Object implements SampleableExecutor, MessageListener<T>, AutoCloseable, Runnable
Mappings:
Namespace Name
official aud
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 Laud;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:
      Mappings:
      Namespace Name Mixin selector
      official b Laud;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:
      Mappings:
      Namespace Name Mixin selector
      official c Laud;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 Laud;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 Laud;e:Lauf;
      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 Laud;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 Laud;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> Laud;<init>(Lauf;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 Laud;a(Ljava/util/concurrent/Executor;Ljava/lang/String;)Laud;
      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 c Laud;c()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 d Laud;d()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 e Laud;e()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 f Laud;f()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 g Laud;g()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
    • awaitAll

      public void awaitAll()
      Mappings:
      Namespace Name Mixin selector
      official a Laud;a()V
      intermediary method_37477 Lnet/minecraft/class_3846;method_37477()V
      named awaitAll Lnet/minecraft/util/thread/TaskExecutor;awaitAll()V
    • send

      public void send(T message)
      Specified by:
      send in interface MessageListener<T>
      Mappings:
      Namespace Name Mixin selector
      official a Lauc;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 h Laud;h()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)
      Parameters:
      condition - checks whether to run another task given the run task count
      Mappings:
      Namespace Name Mixin selector
      official a Laud;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 b Laud;b()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 bn Lauc;bn()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;
    • createSamplers

      public List<Sampler> createSamplers()
      Specified by:
      createSamplers in interface SampleableExecutor
      Mappings:
      Namespace Name Mixin selector
      official bk Lati;bk()Ljava/util/List;
      intermediary method_34705 Lnet/minecraft/class_5952;method_34705()Ljava/util/List;
      named createSamplers Lnet/minecraft/util/thread/SampleableExecutor;createSamplers()Ljava/util/List;