net.minecraft.util.thread

public class TaskExecutor<T>

implements MessageListener<T>, AutoCloseable, Runnable

ais
net.minecraft.util.thread.ProcessorMailbox
net.minecraft.class_3846
net.minecraft.util.thread.TaskExecutor
net.minecraft.unmapped.C_bhuwdyga
net.minecraft.util.concurrent.DelegatedTaskExecutor
net.minecraft.util.concurrent.DelegatedTaskExecutor

Field summary

Modifier and TypeField
private static final org.apache.logging.log4j.Logger
b
LOGGER
field_17040
LOGGER
f_gexlbfjk
field_213153_b
LOGGER
private final AtomicInteger
c
status
field_17041
stateFlags
f_ddxpxjnr
field_213154_c
flags
public final TaskQueue<? super T, ? extends Runnable>
a
queue
field_17039
queue
f_ezvlvaca
field_213152_a
queue
private final Executor
d
dispatcher
field_17042
executor
f_kqzaczae
field_213155_d
delegate
private final String
e
name
field_17043
name
f_eyxbxkvf
field_213156_e
name

Constructor summary

ModifierConstructor
public (TaskQueue<? super T, ? extends Runnable> queue, Executor executor, String name)

Method summary

Modifier and TypeMethod
public static TaskExecutor<Runnable>
a(Executor arg0, String arg1)
create(Executor arg0, String arg1)
method_16902(Executor arg0, String arg1)
create(Executor executor, String name)
m_cobwxwkg(Executor arg0, String arg1)
func_213144_a(Executor arg0, String arg1)
create(Executor arg0, String arg1)
private boolean
a()
setAsScheduled()
method_16903()
unpause()
m_pxwrubzf()
func_213146_a()
setActive()
private void
b()
setAsIdle()
method_16904()
pause()
m_qqqkmemm()
func_213151_b()
clearActive()
private boolean
c()
canBeScheduled()
method_16905()
hasMessages()
m_zrvdymdz()
func_213149_c()
shouldSchedule()
public void
close()
close()
close()
close()
close()
private boolean
d()
shouldProcess()
method_16906()
isUnpaused()
m_ahwfrrlk()
func_213150_d()
isActive()
private boolean
e()
pollTask()
method_16907()
runNext()
m_wsrnretk()
func_213148_e()
driveOne()
public void
run()
run()
run()
run()
run()
public void
a(T arg0)
tell(T arg0)
method_16901(T arg0)
send(T arg0)
m_ihkvxsoy(T arg0)
func_212871_a_(T arg0)
enqueue(T arg0)
private void
f()
registerForExecution()
method_16908()
execute()
m_bkfsdkne()
func_213143_f()
reschedule()
private int
a(it.unimi.dsi.fastutil.ints.Int2BooleanFunction arg0)
pollUntil(it.unimi.dsi.fastutil.ints.Int2BooleanFunction arg0)
method_16900(it.unimi.dsi.fastutil.ints.Int2BooleanFunction arg0)
runWhile(it.unimi.dsi.fastutil.ints.Int2BooleanFunction condition)
m_jmffnwvo(it.unimi.dsi.fastutil.ints.Int2BooleanFunction arg0)
func_213145_a(it.unimi.dsi.fastutil.ints.Int2BooleanFunction arg0)
driveWhile(it.unimi.dsi.fastutil.ints.Int2BooleanFunction arg0)
public String
bh()
name()
method_16898()
getName()
m_lksanyte()
func_213142_bd()
getName()