Class AbstractConsecutiveExecutor<T extends Runnable>

java.lang.Object

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

All Implemented Interfaces:

AutoCloseable, Runnable, ProfilerMeasured, TaskScheduler<T>

Direct Known Subclasses:

ConsecutiveExecutor, PriorityConsecutiveExecutor

public abstract class AbstractConsecutiveExecutor<T extends Runnable>
extends Object
implements Runnable, TaskScheduler<T>, ProfilerMeasured

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static enum	AbstractConsecutiveExecutor.Status

Field Summary

Fields

Modifier and Type	Field	Description
private final Executor	executor
private static final org.slf4j.Logger	LOGGER
private final String	name
private final StrictQueue<T>	queue
private final AtomicReference<AbstractConsecutiveExecutor.Status>	status

Constructor Summary

Constructors

Constructor	Description
AbstractConsecutiveExecutor(StrictQueue<T> queue, Executor executor, String name)

Method Summary

Modifier and Type	Method	Description
private boolean	canBeScheduled()
void	close()
boolean	hasWork()
private boolean	isClosed()
private boolean	isRunning()
String	name()
private boolean	pollTask()
List<MetricSampler>	profiledMetrics()
private void	registerForExecution()
void	run()
void	runAll()
void	schedule(T task)
private boolean	setRunning()
private void	setSleeping()
int	size()
String	toString()

Methods inherited from class Object

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

Methods inherited from interface TaskScheduler

scheduleWithResult, wrapRunnable

Field Details

LOGGER

private static final org.slf4j.Logger LOGGER

status

private final AtomicReference<AbstractConsecutiveExecutor.Status> status

queue

private final StrictQueue<T extends Runnable> queue

executor

private final Executor executor

name

private final String name

Constructor Details

AbstractConsecutiveExecutor

public AbstractConsecutiveExecutor(StrictQueue<T> queue,
 Executor executor,
 String name)

Method Details

canBeScheduled

private boolean canBeScheduled()

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface TaskScheduler<T extends Runnable>

pollTask

private boolean pollTask()

run

public void run()

Specified by:

run in interface Runnable

runAll

public void runAll()

schedule

public void schedule(T task)

Specified by:

schedule in interface TaskScheduler<T extends Runnable>

registerForExecution

private void registerForExecution()

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 TaskScheduler<T extends Runnable>

profiledMetrics

public List<MetricSampler> profiledMetrics()

Specified by:

profiledMetrics in interface ProfilerMeasured

setRunning

private boolean setRunning()

setSleeping

private void setSleeping()

isRunning

private boolean isRunning()

isClosed

private boolean isClosed()