Package net.minecraft.util.thread

Class ConsecutiveExecutor<T extends Runnable>

java.lang.Object

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

All Implemented Interfaces:

AutoCloseable, Runnable, SampleableExecutor, TaskExecutor<T>

Direct Known Subclasses:

PrioritizedConsecutiveExecutor, SimpleConsecutiveExecutor

public abstract class ConsecutiveExecutor<T extends Runnable>
extends Object
implements SampleableExecutor, TaskExecutor<T>, Runnable

Mappings:

Namespace	Name
named	net/minecraft/util/thread/ConsecutiveExecutor
intermediary	net/minecraft/class_10174
official	brw

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static enum	ConsecutiveExecutor.Status

Field Summary

Fields

Modifier and Type	Field	Description
private final Executor	executor
private static final Logger	LOGGER
private final String	name
private final TaskQueue<T>	queue
private final AtomicReference<ConsecutiveExecutor.Status>	status

Constructor Summary

Constructors

Constructor	Description
ConsecutiveExecutor(TaskQueue<T> queue, Executor executor, String name)

Method Summary

Modifier and Type	Method	Description
private boolean	canRun()
void	close()
List<Sampler>	createSamplers()
String	getName()
boolean	hasQueuedTasks()
private boolean	isClosed()
private boolean	isRunning()
int	queueSize()
void	run()
void	runAll()
private boolean	runOnce()
private void	scheduleSelf()
void	send(T runnable)
private void	sleep()
String	toString()
private boolean	wakeUp()

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.TaskExecutor

createTask, executeAsync

Field Details

LOGGER

private static final Logger LOGGER

Mappings:

Namespace	Name	Mixin selector
named	LOGGER	Lnet/minecraft/util/thread/ConsecutiveExecutor;LOGGER:Lorg/slf4j/Logger;
intermediary	field_54069	Lnet/minecraft/class_10174;field_54069:Lorg/slf4j/Logger;
official	a	Lbrw;a:Lorg/slf4j/Logger;

status

private final AtomicReference<ConsecutiveExecutor.Status> status

Mappings:

Namespace	Name	Mixin selector
named	status	Lnet/minecraft/util/thread/ConsecutiveExecutor;status:Ljava/util/concurrent/atomic/AtomicReference;
intermediary	field_54070	Lnet/minecraft/class_10174;field_54070:Ljava/util/concurrent/atomic/AtomicReference;
official	b	Lbrw;b:Ljava/util/concurrent/atomic/AtomicReference;

queue

private final TaskQueue<T extends Runnable> queue

Mappings:

Namespace	Name	Mixin selector
named	queue	Lnet/minecraft/util/thread/ConsecutiveExecutor;queue:Lnet/minecraft/util/thread/TaskQueue;
intermediary	field_54071	Lnet/minecraft/class_10174;field_54071:Lnet/minecraft/class_3847;
official	c	Lbrw;c:Lbsc;

executor

private final Executor executor

Mappings:

Namespace	Name	Mixin selector
named	executor	Lnet/minecraft/util/thread/ConsecutiveExecutor;executor:Ljava/util/concurrent/Executor;
intermediary	field_54072	Lnet/minecraft/class_10174;field_54072:Ljava/util/concurrent/Executor;
official	d	Lbrw;d:Ljava/util/concurrent/Executor;

name

private final String name

Mappings:

Namespace	Name	Mixin selector
named	name	Lnet/minecraft/util/thread/ConsecutiveExecutor;name:Ljava/lang/String;
intermediary	field_54073	Lnet/minecraft/class_10174;field_54073:Ljava/lang/String;
official	e	Lbrw;e:Ljava/lang/String;

Constructor Details

ConsecutiveExecutor

public ConsecutiveExecutor(TaskQueue<T> queue,
 Executor executor,
 String name)

Mappings:

Namespace	Name	Mixin selector
named	<init>	Lnet/minecraft/util/thread/ConsecutiveExecutor;<init>(Lnet/minecraft/util/thread/TaskQueue;Ljava/util/concurrent/Executor;Ljava/lang/String;)V
intermediary	<init>	Lnet/minecraft/class_10174;<init>(Lnet/minecraft/class_3847;Ljava/util/concurrent/Executor;Ljava/lang/String;)V
official	<init>	Lbrw;<init>(Lbsc;Ljava/util/concurrent/Executor;Ljava/lang/String;)V

Method Details

canRun

private boolean canRun()

Mappings:

Namespace	Name	Mixin selector
named	canRun	Lnet/minecraft/util/thread/ConsecutiveExecutor;canRun()Z
intermediary	method_63591	Lnet/minecraft/class_10174;method_63591()Z
official	e	Lbrw;e()Z

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface TaskExecutor<T extends Runnable>

runOnce

private boolean runOnce()

Mappings:

Namespace	Name	Mixin selector
named	runOnce	Lnet/minecraft/util/thread/ConsecutiveExecutor;runOnce()Z
intermediary	method_63592	Lnet/minecraft/class_10174;method_63592()Z
official	f	Lbrw;f()Z

run

public void run()

Specified by:

run in interface Runnable

runAll

public void runAll()

Mappings:

Namespace	Name	Mixin selector
named	runAll	Lnet/minecraft/util/thread/ConsecutiveExecutor;runAll()V
intermediary	method_63587	Lnet/minecraft/class_10174;method_63587()V
official	a	Lbrw;a()V

send

public void send(T runnable)

Specified by:

send in interface TaskExecutor<T extends Runnable>

Mappings:

Namespace	Name	Mixin selector
named	send	Lnet/minecraft/util/thread/TaskExecutor;send(Ljava/lang/Runnable;)V
intermediary	method_63588	Lnet/minecraft/class_10178;method_63588(Ljava/lang/Runnable;)V
official	a_	Lbsd;a_(Ljava/lang/Runnable;)V

scheduleSelf

private void scheduleSelf()

Mappings:

Namespace	Name	Mixin selector
named	scheduleSelf	Lnet/minecraft/util/thread/ConsecutiveExecutor;scheduleSelf()V
intermediary	method_63593	Lnet/minecraft/class_10174;method_63593()V
official	g	Lbrw;g()V

queueSize

public int queueSize()

Mappings:

Namespace	Name	Mixin selector
named	queueSize	Lnet/minecraft/util/thread/ConsecutiveExecutor;queueSize()I
intermediary	method_63589	Lnet/minecraft/class_10174;method_63589()I
official	b	Lbrw;b()I

hasQueuedTasks

public boolean hasQueuedTasks()

Mappings:

Namespace	Name	Mixin selector
named	hasQueuedTasks	Lnet/minecraft/util/thread/ConsecutiveExecutor;hasQueuedTasks()Z
intermediary	method_63590	Lnet/minecraft/class_10174;method_63590()Z
official	c	Lbrw;c()Z

toString

public String toString()

Overrides:

toString in class Object

getName

public String getName()

Specified by:

getName in interface TaskExecutor<T extends Runnable>

Mappings:

Namespace	Name	Mixin selector
named	getName	Lnet/minecraft/util/thread/TaskExecutor;getName()Ljava/lang/String;
intermediary	method_16898	Lnet/minecraft/class_10178;method_16898()Ljava/lang/String;
official	A_	Lbsd;A_()Ljava/lang/String;

createSamplers

public List<Sampler> createSamplers()

Specified by:

createSamplers in interface SampleableExecutor

Mappings:

Namespace	Name	Mixin selector
named	createSamplers	Lnet/minecraft/util/thread/SampleableExecutor;createSamplers()Ljava/util/List;
intermediary	method_34705	Lnet/minecraft/class_5952;method_34705()Ljava/util/List;
official	bw	Lbre;bw()Ljava/util/List;

wakeUp

private boolean wakeUp()

Mappings:

Namespace	Name	Mixin selector
named	wakeUp	Lnet/minecraft/util/thread/ConsecutiveExecutor;wakeUp()Z
intermediary	method_63594	Lnet/minecraft/class_10174;method_63594()Z
official	h	Lbrw;h()Z

sleep

private void sleep()

Mappings:

Namespace	Name	Mixin selector
named	sleep	Lnet/minecraft/util/thread/ConsecutiveExecutor;sleep()V
intermediary	method_63595	Lnet/minecraft/class_10174;method_63595()V
official	i	Lbrw;i()V

isRunning

private boolean isRunning()

Mappings:

Namespace	Name	Mixin selector
named	isRunning	Lnet/minecraft/util/thread/ConsecutiveExecutor;isRunning()Z
intermediary	method_63596	Lnet/minecraft/class_10174;method_63596()Z
official	j	Lbrw;j()Z

isClosed

private boolean isClosed()

Mappings:

Namespace	Name	Mixin selector
named	isClosed	Lnet/minecraft/util/thread/ConsecutiveExecutor;isClosed()Z
intermediary	method_63597	Lnet/minecraft/class_10174;method_63597()Z
official	k	Lbrw;k()Z