Package net.minecraft.util.thread

Class ProcessorMailbox<T>

java.lang.Object

net.minecraft.util.thread.ProcessorMailbox<T>

All Implemented Interfaces:

AutoCloseable, Runnable, ProfilerMeasured, ProcessorHandle<T>

public class ProcessorMailbox<T>
extends Object
implements ProfilerMeasured, ProcessorHandle<T>, AutoCloseable, Runnable

Field Summary

Fields

Modifier and Type	Field	Description
private static final int	CLOSED_BIT
private final Executor	dispatcher
private static final org.slf4j.Logger	LOGGER
private final String	name
private final StrictQueue<? super T,? extends Runnable>	queue
private static final int	SCHEDULED_BIT
private final AtomicInteger	status

Constructor Summary

Constructors

Constructor	Description
ProcessorMailbox(StrictQueue<? super T,? extends Runnable> p_18741_, Executor p_18742_, String p_18743_)

Method Summary

Modifier and Type	Method	Description
private boolean	canBeScheduled()
void	close()
static ProcessorMailbox<Runnable>	create(Executor p_18752_, String p_18753_)
boolean	hasWork()
String	name()
private boolean	pollTask()
private int	pollUntil(it.unimi.dsi.fastutil.ints.Int2BooleanFunction p_18748_)
List<MetricSampler>	profiledMetrics()
private void	registerForExecution()
void	run()
void	runAll()
private void	setAsIdle()
private boolean	setAsScheduled()
private boolean	shouldProcess()
int	size()
void	tell(T p_18750_)
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface net.minecraft.util.thread.ProcessorHandle

ask, askEither

Field Details

LOGGER

private static final org.slf4j.Logger LOGGER

CLOSED_BIT

private static final int CLOSED_BIT

See Also:

• Constant Field Values

SCHEDULED_BIT

private static final int SCHEDULED_BIT

See Also:

• Constant Field Values

status

private final AtomicInteger status

queue

private final StrictQueue<? super T,? extends Runnable> queue

dispatcher

private final Executor dispatcher

name

private final String name

Constructor Details

ProcessorMailbox

public ProcessorMailbox(StrictQueue<? super T,? extends Runnable> p_18741_,
 Executor p_18742_,
 String p_18743_)

Method Details

create

public static ProcessorMailbox<Runnable> create(Executor p_18752_,
 String p_18753_)

setAsScheduled

private boolean setAsScheduled()

setAsIdle

private void setAsIdle()

canBeScheduled

private boolean canBeScheduled()

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface ProcessorHandle<T>

shouldProcess

private boolean shouldProcess()

pollTask

private boolean pollTask()

run

public void run()

Specified by:

run in interface Runnable

runAll

public void runAll()

tell

public void tell(T p_18750_)

Specified by:

tell in interface ProcessorHandle<T>

registerForExecution

private void registerForExecution()

pollUntil

private int pollUntil(it.unimi.dsi.fastutil.ints.Int2BooleanFunction p_18748_)

size

public int size()

hasWork

public boolean hasWork()

toString

public String toString()

Overrides:

toString in class Object

name

public String name()

Specified by:

name in interface ProcessorHandle<T>

profiledMetrics

public List<MetricSampler> profiledMetrics()

Specified by:

profiledMetrics in interface ProfilerMeasured