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.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
LOGGER
f_18735_
private static final int
b
CLOSED_BIT
field_29940
field_29940
f_146353_
private static final int
c
SCHEDULED_BIT
field_29941
field_29941
f_146354_
private final AtomicInteger
d
status
field_17041
stateFlags
f_18736_
private final StrictQueue<? super T, ? extends Runnable>
e
queue
field_17039
queue
f_18734_
private final Executor
f
dispatcher
field_17042
executor
f_18737_
private final String
g
name
field_17043
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)
create(Executor executor, String name)
m_18751_(Executor p_18752_, String p_18753_)
private boolean
d()
setAsScheduled()
method_16903()
unpause()
m_18744_()
private void
e()
setAsIdle()
method_16904()
pause()
m_18754_()
private boolean
f()
canBeScheduled()
method_16905()
hasMessages()
m_18756_()
public void
close()
close()
close()
private boolean
g()
shouldProcess()
method_16906()
isUnpaused()
m_18758_()
private boolean
h()
pollTask()
method_16907()
runNext()
m_18759_()
public void
run()
run()
run()
public void
a()
runAll()
method_37477()
awaitAll()
m_182329_()
public void
a(T arg0)
tell(T arg0)
method_16901(T arg0)
send(T arg0)
m_6937_(T arg0)
private void
i()
registerForExecution()
method_16908()
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)
runWhile(it.unimi.dsi.fastutil.ints.Int2BooleanFunction condition)
m_18747_(it.unimi.dsi.fastutil.ints.Int2BooleanFunction arg0)
public int
b()
size()
method_34996()
getQueueSize()
m_146355_()
public boolean
c()
hasWork()
method_40001()
hasQueuedTasks()
m_201938_()
public String
bz()
name()
method_16898()
getName()
m_7326_()
public List<MetricSampler>
bw()
profiledMetrics()
method_34705()
createSamplers()
m_142754_()