net.minecraft.util.thread

Class TaskExecutor<T>

java.lang.Object

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

All Implemented Interfaces:

AutoCloseable, Runnable, MessageListener<T>

public class TaskExecutor<T>
extends Object
implements MessageListener<T>, AutoCloseable, Runnable

Field Summary

Fields

Modifier and Type	Field and Description
private Executor	executor
private static Logger	LOGGER
private String	name
TaskQueue<? super T,? extends Runnable>	queue
private AtomicInteger	stateFlags

Constructor Summary

Constructors

Constructor and Description
TaskExecutor(TaskQueue<? super T,? extends Runnable> queue, Executor executor, String name)

Method Summary

Modifier and Type	Method and Description
void	close()
static TaskExecutor<Runnable>	create(Executor executor, String name)
private void	execute()
String	getName()
private boolean	hasMessages()
private boolean	isUnpaused()
private void	pause()
void	run()
private boolean	runNext()
private int	runWhile(it.unimi.dsi.fastutil.ints.Int2BooleanFunction condition)
void	send(T message)
String	toString()
private boolean	unpause()

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

ask, create, method_27918

Field Detail

LOGGER

private static final Logger LOGGER

stateFlags

private final AtomicInteger stateFlags

queue

public final TaskQueue<? super T,? extends Runnable> queue

executor

private final Executor executor

name

private final String name

Constructor Detail

TaskExecutor

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

Method Detail

create

public static TaskExecutor<Runnable> create(Executor executor,
                                            String name)

unpause

private boolean unpause()

pause

private void pause()

hasMessages

private boolean hasMessages()

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface MessageListener<T>

isUnpaused

private boolean isUnpaused()

runNext

private boolean runNext()

run

public void run()

Specified by:

run in interface Runnable

send

public void send(T message)

Specified by:

send in interface MessageListener<T>

execute

private void execute()

runWhile

private int runWhile(it.unimi.dsi.fastutil.ints.Int2BooleanFunction condition)

toString

public String toString()

Overrides:

toString in class Object

getName

public String getName()

Specified by:

getName in interface MessageListener<T>