Package net.minecraft.util.thread
Class TaskExecutor<T>
java.lang.Object
net.minecraft.util.thread.TaskExecutor<T>
- All Implemented Interfaces:
AutoCloseable,Runnable,MessageListener<T>
public class TaskExecutor<T> extends Object implements MessageListener<T>, AutoCloseable, Runnable
- Mappings:
Namespace Name official apcintermediary net/minecraft/class_3846named net/minecraft/util/thread/TaskExecutor
-
Field Summary
-
Constructor Summary
-
Method Summary
Modifier and Type Method Description voidclose()static TaskExecutor<Runnable>create(Executor executor, String name)private voidexecute()StringgetName()private booleanhasMessages()private booleanisUnpaused()private voidpause()voidrun()private booleanrunNext()private intrunWhile(Int2BooleanFunction condition)voidsend(T message)StringtoString()private booleanunpause()Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitMethods inherited from interface net.minecraft.util.thread.MessageListener
ask, askFallible
-
Field Details
-
LOGGER
- Mappings:
Namespace Name Mixin selector official bLapc;b:Lorg/apache/logging/log4j/Logger;intermediary field_17040Lnet/minecraft/class_3846;field_17040:Lorg/apache/logging/log4j/Logger;named LOGGERLnet/minecraft/util/thread/TaskExecutor;LOGGER:Lorg/apache/logging/log4j/Logger;
-
stateFlags
- Mappings:
Namespace Name Mixin selector official cLapc;c:Ljava/util/concurrent/atomic/AtomicInteger;intermediary field_17041Lnet/minecraft/class_3846;field_17041:Ljava/util/concurrent/atomic/AtomicInteger;named stateFlagsLnet/minecraft/util/thread/TaskExecutor;stateFlags:Ljava/util/concurrent/atomic/AtomicInteger;
-
queue
- Mappings:
Namespace Name Mixin selector official aLapc;a:Lape;intermediary field_17039Lnet/minecraft/class_3846;field_17039:Lnet/minecraft/class_3847;named queueLnet/minecraft/util/thread/TaskExecutor;queue:Lnet/minecraft/util/thread/TaskQueue;
-
executor
- Mappings:
Namespace Name Mixin selector official dLapc;d:Ljava/util/concurrent/Executor;intermediary field_17042Lnet/minecraft/class_3846;field_17042:Ljava/util/concurrent/Executor;named executorLnet/minecraft/util/thread/TaskExecutor;executor:Ljava/util/concurrent/Executor;
-
name
- Mappings:
Namespace Name Mixin selector official eLapc;e:Ljava/lang/String;intermediary field_17043Lnet/minecraft/class_3846;field_17043:Ljava/lang/String;named nameLnet/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>Lapc;<init>(Lape;Ljava/util/concurrent/Executor;Ljava/lang/String;)Vintermediary <init>Lnet/minecraft/class_3846;<init>(Lnet/minecraft/class_3847;Ljava/util/concurrent/Executor;Ljava/lang/String;)Vnamed <init>Lnet/minecraft/util/thread/TaskExecutor;<init>(Lnet/minecraft/util/thread/TaskQueue;Ljava/util/concurrent/Executor;Ljava/lang/String;)V
-
-
Method Details
-
create
- Mappings:
Namespace Name Mixin selector official aLapc;a(Ljava/util/concurrent/Executor;Ljava/lang/String;)Lapc;intermediary method_16902Lnet/minecraft/class_3846;method_16902(Ljava/util/concurrent/Executor;Ljava/lang/String;)Lnet/minecraft/class_3846;named createLnet/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 aLapc;a()Zintermediary method_16903Lnet/minecraft/class_3846;method_16903()Znamed unpauseLnet/minecraft/util/thread/TaskExecutor;unpause()Z
-
pause
private void pause()- Mappings:
Namespace Name Mixin selector official bLapc;b()Vintermediary method_16904Lnet/minecraft/class_3846;method_16904()Vnamed pauseLnet/minecraft/util/thread/TaskExecutor;pause()V
-
hasMessages
private boolean hasMessages()- Mappings:
Namespace Name Mixin selector official cLapc;c()Zintermediary method_16905Lnet/minecraft/class_3846;method_16905()Znamed hasMessagesLnet/minecraft/util/thread/TaskExecutor;hasMessages()Z
-
close
public void close()- Specified by:
closein interfaceAutoCloseable- Specified by:
closein interfaceMessageListener<T>- Mappings:
Namespace Name Mixin selector official closeLapb;close()Vintermediary closeLnet/minecraft/class_3906;close()Vnamed closeLnet/minecraft/util/thread/MessageListener;close()V
-
isUnpaused
private boolean isUnpaused()- Mappings:
Namespace Name Mixin selector official dLapc;d()Zintermediary method_16906Lnet/minecraft/class_3846;method_16906()Znamed isUnpausedLnet/minecraft/util/thread/TaskExecutor;isUnpaused()Z
-
runNext
private boolean runNext()- Mappings:
Namespace Name Mixin selector official eLapc;e()Zintermediary method_16907Lnet/minecraft/class_3846;method_16907()Znamed runNextLnet/minecraft/util/thread/TaskExecutor;runNext()Z
-
run
public void run() -
send
- Specified by:
sendin interfaceMessageListener<T>- Mappings:
Namespace Name Mixin selector official aLapb;a(Ljava/lang/Object;)Vintermediary method_16901Lnet/minecraft/class_3906;method_16901(Ljava/lang/Object;)Vnamed sendLnet/minecraft/util/thread/MessageListener;send(Ljava/lang/Object;)V
-
execute
private void execute()- Mappings:
Namespace Name Mixin selector official fLapc;f()Vintermediary method_16908Lnet/minecraft/class_3846;method_16908()Vnamed executeLnet/minecraft/util/thread/TaskExecutor;execute()V
-
runWhile
- Mappings:
Namespace Name Mixin selector official aLapc;a(Lit/unimi/dsi/fastutil/ints/Int2BooleanFunction;)Iintermediary method_16900Lnet/minecraft/class_3846;method_16900(Lit/unimi/dsi/fastutil/ints/Int2BooleanFunction;)Inamed runWhileLnet/minecraft/util/thread/TaskExecutor;runWhile(Lit/unimi/dsi/fastutil/ints/Int2BooleanFunction;)I
-
toString
-
getName
- Specified by:
getNamein interfaceMessageListener<T>- Mappings:
Namespace Name Mixin selector official bjLapb;bj()Ljava/lang/String;intermediary method_16898Lnet/minecraft/class_3906;method_16898()Ljava/lang/String;named getNameLnet/minecraft/util/thread/MessageListener;getName()Ljava/lang/String;
-