Package net.minecraft.util.thread

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 bcq
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 Lbcq;a:Lorg/slf4j/Logger;
      intermediary field_17040 Lnet/minecraft/class_3846;field_17040:Lorg/slf4j/Logger;
      named LOGGER Lnet/minecraft/util/thread/TaskExecutor;LOGGER:Lorg/slf4j/Logger;

    • field_29940

      private static final int field_29940
      See Also:
      Mappings:
      Namespace Name Mixin selector
      official b Lbcq;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 Lbcq;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 Lbcq;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 Lbcq;e:Lbcs;
      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 Lbcq;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 Lbcq;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> Lbcq;<init>(Lbcs;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 Lbcq;a(Ljava/util/concurrent/Executor;Ljava/lang/String;)Lbcq;
      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 d Lbcq;d()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 e Lbcq;e()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 f Lbcq;f()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 g Lbcq;g()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 h Lbcq;h()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 Lbcq;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 Lbcp;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 i Lbcq;i()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 Lbcq;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 Lbcq;b()I
      intermediary method_34996 Lnet/minecraft/class_3846;method_34996()I
      named getQueueSize Lnet/minecraft/util/thread/TaskExecutor;getQueueSize()I

    • hasQueuedTasks

      public boolean hasQueuedTasks()
      Mappings:
      Namespace Name Mixin selector
      official c Lbcq;c()Z
      intermediary method_40001 Lnet/minecraft/class_3846;method_40001()Z
      named hasQueuedTasks Lnet/minecraft/util/thread/TaskExecutor;hasQueuedTasks()Z

    • 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 Lbcp;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 Lbbv;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;