net.minecraft.util.thread

public class ProcessorMailbox<T>

implements ProfilerMeasured, ProcessorHandle<T>, AutoCloseable, Runnable

bpk
net.minecraft.util.thread.ProcessorMailbox
net.minecraft.class_3846
net.minecraft.unmapped.C_bhuwdyga
net.minecraft.util.thread.TaskExecutor
net.minecraft.util.thread.TaskExecutor
net.minecraft.src.C_452_
net.minecraft.util.thread.ThreadedMailbox

Field summary

Modifier and TypeField
private static final org.slf4j.Logger
a
LOGGER
field_17040
f_gexlbfjk
LOGGER
LOGGER
f_18735_
private static final int
b
CLOSED_BIT
field_29940
f_glbnuleu
field_29940
CLOSED_BIT
f_146353_
private static final int
c
SCHEDULED_BIT
field_29941
f_vditdweq
field_29941
SCHEDULED_BIT
f_146354_
private final AtomicInteger
d
status
field_17041
f_ddxpxjnr
stateFlags
stateFlags
f_18736_
private final StrictQueue<? super T, ? extends Runnable>
e
queue
field_17039
f_ezvlvaca
queue
queue
f_18734_
private final Executor
f
dispatcher
field_17042
f_kqzaczae
executor
executor
f_18737_
private final String
g
name
field_17043
f_eyxbxkvf
name
name
f_18738_

Constructor summary

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

Method summary

Modifier and TypeMethod
public static ProcessorMailbox<Runnable>
a(Executor arg0, String arg1)
create(Executor arg0, String arg1)
method_16902(Executor arg0, String arg1)
m_cobwxwkg(Executor arg0, String arg1)
create(Executor executor, String name)
create(Executor executor, String name)
m_18751_(Executor p_18752_, String p_18753_)
private boolean
d()
setAsScheduled()
method_16903()
m_pxwrubzf()
unpause()
unpause()
m_18744_()
private void
e()
setAsIdle()
method_16904()
m_qqqkmemm()
pause()
pause()
m_18754_()
private boolean
f()
canBeScheduled()
method_16905()
m_zrvdymdz()
hasMessages()
hasMessages()
m_18756_()
public void
close()
close()
close()
private boolean
g()
shouldProcess()
method_16906()
m_ahwfrrlk()
isUnpaused()
isUnpaused()
m_18758_()
private boolean
h()
pollTask()
method_16907()
m_wsrnretk()
runNext()
runNext()
m_18759_()
public void
run()
run()
run()
public void
a()
runAll()
method_37477()
m_ymxohols()
awaitAll()
awaitAll()
m_182329_()
public void
a(T arg0)
tell(T arg0)
method_16901(T arg0)
m_ihkvxsoy(T arg0)
send(T arg0)
send(T arg0)
m_6937_(T arg0)
private void
i()
registerForExecution()
method_16908()
m_bkfsdkne()
execute()
execute()
m_18760_()
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)
m_jmffnwvo(it.unimi.dsi.fastutil.ints.Int2BooleanFunction arg0)
runWhile(it.unimi.dsi.fastutil.ints.Int2BooleanFunction condition)
runWhile(it.unimi.dsi.fastutil.ints.Int2BooleanFunction condition)
m_18747_(it.unimi.dsi.fastutil.ints.Int2BooleanFunction arg0)
public int
b()
size()
method_34996()
m_nuruqysr()
getQueueSize()
getQueueSize()
m_146355_()
public boolean
c()
hasWork()
method_40001()
m_zlrwnsoz()
hasQueuedTasks()
hasWork()
m_201938_()
public String
bz()
name()
method_16898()
m_lksanyte()
getName()
getName()
m_7326_()
public List<MetricSampler>
bw()
profiledMetrics()
method_34705()
m_xvatidod()
createSamplers()
createSamplers()
m_142754_()