Package net.minecraft.util.thread

Class ThreadExecutor<R extends Runnable>

java.lang.Object

net.minecraft.util.thread.ThreadExecutor<R>

All Implemented Interfaces:

AutoCloseable, Executor, MessageListener<R>

Direct Known Subclasses:

ReentrantThreadExecutor, ServerChunkManager.MainThreadExecutor, SoundExecutor

public abstract class ThreadExecutor<R extends Runnable>
extends Object
implements MessageListener<R>, Executor

Field Summary

Fields

Modifier and Type	Field	Description
private int	executionsInProgress
private static Logger	LOGGER
private String	name
private Queue<R>	tasks

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ThreadExecutor(String name)

Method Summary

Modifier and Type	Method	Description
protected void	cancelTasks()
protected abstract boolean	canExecute(R task)
protected abstract R	createTask(Runnable runnable)
void	execute(Runnable runnable)
protected void	executeTask(R task)
String	getName()
int	getTaskCount()
protected abstract Thread	getThread()
boolean	isOnThread()
protected boolean	runTask()
protected void	runTasks()
void	runTasks(BooleanSupplier stopCondition)
void	send(R r)
protected boolean	shouldExecuteAsync()
CompletableFuture<Void>	submit(Runnable task)
<V> CompletableFuture<V>	submit(Supplier<V> task)
void	submitAndJoin(Runnable runnable)
private CompletableFuture<Void>	submitAsync(Runnable runnable)
protected void	waitForTasks()

Methods inherited from class java.lang.Object

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

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

ask, close, method_27918

Field Details

LOGGER

private static final Logger LOGGER

name

private final String name

tasks

private final Queue<R extends Runnable> tasks

executionsInProgress

private int executionsInProgress

Constructor Details

ThreadExecutor

protected ThreadExecutor(String name)

Method Details

createTask

protected abstract R createTask(Runnable runnable)

canExecute

protected abstract boolean canExecute(R task)

isOnThread

public boolean isOnThread()

getThread

protected abstract Thread getThread()

shouldExecuteAsync

protected boolean shouldExecuteAsync()

getTaskCount

public int getTaskCount()

getName

public String getName()

Specified by:

getName in interface MessageListener<R extends Runnable>

submit

@Environment(CLIENT) public <V> CompletableFuture<V> submit(Supplier<V> task)

submitAsync

private CompletableFuture<Void> submitAsync(Runnable runnable)

submit

public CompletableFuture<Void> submit(Runnable task)

submitAndJoin

public void submitAndJoin(Runnable runnable)

send

public void send(R r)

Specified by:

send in interface MessageListener<R extends Runnable>

execute

public void execute(Runnable runnable)

Specified by:

execute in interface Executor

cancelTasks

@Environment(CLIENT) protected void cancelTasks()

runTasks

protected void runTasks()

runTask

protected boolean runTask()

runTasks

public void runTasks(BooleanSupplier stopCondition)

waitForTasks

protected void waitForTasks()

executeTask

protected void executeTask(R task)