net.minecraft.util.thread

public abstract class ThreadExecutor<R extends Runnable>

implements MessageListener<R>, Executor

aip
net.minecraft.util.thread.BlockableEventLoop
net.minecraft.class_1255
net.minecraft.util.thread.ThreadExecutor
net.minecraft.unmapped.C_wfxvpelc
net.minecraft.util.concurrent.ThreadTaskExecutor
net.minecraft.util.concurrent.ThreadTaskExecutor

Field summary

Modifier and TypeField
private final String
b
name
field_18318
name
f_jbvsaprb
field_213171_b
name
private static final org.apache.logging.log4j.Logger
c
LOGGER
field_5751
LOGGER
f_kxdzbkhv
field_213172_c
LOGGER
private final Queue<R>
d
pendingRunnables
field_5750
tasks
f_yvtuopon
field_213173_d
queue
private int
e
blockingCount
field_18319
executionsInProgress
f_pfyykeai
field_213174_e
drivers

Constructor summary

ModifierConstructor
protected (String name)

Method summary

Modifier and TypeMethod
protected abstract R
d(Runnable arg0)
wrapRunnable(Runnable arg0)
method_16211(Runnable arg0)
createTask(Runnable runnable)
m_lougoxia(Runnable arg0)
func_212875_d_(Runnable arg0)
wrapTask(Runnable runnable)
protected abstract boolean
c(R arg0)
shouldRun(R arg0)
method_18856(R arg0)
canExecute(R task)
m_numnjvus(R arg0)
func_212874_c_(R arg0)
canRun(R runnable)
public boolean
bf()
isSameThread()
method_18854()
isOnThread()
m_zpwzffjx()
func_213162_bc()
isOnExecutionThread()
protected abstract Thread
ay()
getRunningThread()
method_3777()
getThread()
m_uvhkkife()
func_213170_ax()
getExecutionThread()
protected boolean
ax()
scheduleExecutables()
method_5384()
shouldExecuteAsync()
m_hpnksayn()
func_213164_aw()
shouldDeferTasks()
public int
bg()
getPendingTasksCount()
method_21684()
getTaskCount()
m_ujgbwjcf()
func_223704_be()
func_223704_be()
public String
bh()
name()
method_16898()
getName()
m_lksanyte()
func_213142_bd()
getName()
private CompletableFuture<Void>
a(Runnable arg0)
submitAsync(Runnable arg0)
method_5382(Runnable arg0)
submitAsync(Runnable runnable)
m_jurnilqy(Runnable arg0)
func_213165_a(Runnable arg0)
deferTask(Runnable taskIn)
public CompletableFuture<Void>
e(Runnable arg0)
submit(Runnable arg0)
method_20493(Runnable arg0)
submit(Runnable task)
m_edmwbzwp(Runnable arg0)
func_222817_e(Runnable arg0)
runAsync(Runnable taskIn)
public void
f(Runnable arg0)
executeBlocking(Runnable arg0)
method_19537(Runnable arg0)
submitAndJoin(Runnable runnable)
m_qqwrpvfd(Runnable arg0)
func_213167_f(Runnable arg0)
runImmediately(Runnable taskIn)
public void
g(R arg0)
tell(R arg0)
method_18858(R arg0)
send(R arg0)
m_bfryvklq(R arg0)
func_212871_a_(R arg0)
enqueue(R taskIn)
public void
execute(Runnable arg0)
execute(Runnable arg0)
execute(Runnable arg0)
execute(Runnable runnable)
execute(Runnable arg0)
execute(Runnable arg0)
protected void
bj()
runAllTasks()
method_5383()
runTasks()
m_vgbcguai()
func_213160_bf()
drainTasks()
protected boolean
v()
pollTask()
method_16075()
runTask()
m_yxzbunwm()
func_213168_p()
driveOne()
public void
c(BooleanSupplier arg0)
managedBlock(BooleanSupplier arg0)
method_18857(BooleanSupplier arg0)
runTasks(BooleanSupplier stopCondition)
m_awpmlrph(BooleanSupplier arg0)
func_213161_c(BooleanSupplier arg0)
driveUntil(BooleanSupplier isDone)
protected void
bk()
waitForTasks()
method_20813()
waitForTasks()
m_xakfizli()
func_223705_bi()
func_223705_bi()
protected void
h(R arg0)
doRunTask(R arg0)
method_18859(R arg0)
executeTask(R task)
m_eqxaqhzn(R arg0)
func_213166_h(R arg0)
run(R taskIn)
public <V> CompletableFuture<V>
a(Supplier<V> arg0)
submit(Supplier<V> arg0)
method_5385(Supplier<V> arg0)
submit(Supplier<V> task)
m_hxqyzuvd(Supplier<V> arg0)
func_213169_a(Supplier<V> arg0)
supplyAsync(Supplier<V> supplier)
protected void
bi()
dropAllTasks()
method_18855()
cancelTasks()
m_cevutxgz()
func_213159_be()
dropTasks()