net.minecraft.util.concurrent

Class ThreadTaskExecutor<R extends java.lang.Runnable>

java.lang.Object

net.minecraft.util.concurrent.ThreadTaskExecutor<R>

All Implemented Interfaces:

java.lang.AutoCloseable, java.util.concurrent.Executor, ITaskExecutor<R>

Direct Known Subclasses:

RecursiveEventLoop, ServerChunkProvider.ChunkExecutor, SoundEngineExecutor

public abstract class ThreadTaskExecutor<R extends java.lang.Runnable>
extends java.lang.Object
implements ITaskExecutor<R>, java.util.concurrent.Executor

Field Summary

Fields

Modifier and Type	Field and Description
private int	drivers
private static org.apache.logging.log4j.Logger	LOGGER
private java.lang.String	name
private java.util.Queue<R>	queue

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	ThreadTaskExecutor(java.lang.String nameIn)

Method Summary

Modifier and Type	Method and Description
protected abstract boolean	canRun(R runnable)
java.util.concurrent.CompletableFuture<java.lang.Void>	deferTask(java.lang.Runnable taskIn)
protected void	drainTasks()
protected boolean	driveOne()
void	driveUntil(java.util.function.BooleanSupplier isDone)
protected void	dropTasks()
void	enqueue(R taskIn)
void	execute(java.lang.Runnable p_execute_1_)
protected abstract java.lang.Thread	getExecutionThread()
java.lang.String	getName()
int	getQueueSize()
boolean	isOnExecutionThread()
protected void	run(R taskIn)
java.util.concurrent.CompletableFuture<java.lang.Void>	runAsync(java.lang.Runnable taskIn)
void	runImmediately(java.lang.Runnable taskIn)
protected boolean	shouldDeferTasks()
<V> java.util.concurrent.CompletableFuture<V>	supplyAsync(java.util.function.Supplier<V> supplier)
protected void	threadYieldPark()
protected abstract R	wrapTask(java.lang.Runnable runnable)

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.concurrent.ITaskExecutor

close, func_213141_a, inline

Field Detail

name

private final java.lang.String name

LOGGER

private static final org.apache.logging.log4j.Logger LOGGER

queue

private final java.util.Queue<R extends java.lang.Runnable> queue

drivers

private int drivers

Constructor Detail

ThreadTaskExecutor

protected ThreadTaskExecutor(java.lang.String nameIn)

Method Detail

wrapTask

protected abstract R wrapTask(java.lang.Runnable runnable)

canRun

protected abstract boolean canRun(R runnable)

isOnExecutionThread

public boolean isOnExecutionThread()

getExecutionThread

protected abstract java.lang.Thread getExecutionThread()

shouldDeferTasks

protected boolean shouldDeferTasks()

getQueueSize

public int getQueueSize()

getName

public java.lang.String getName()

Specified by:

getName in interface ITaskExecutor<R extends java.lang.Runnable>

supplyAsync

public <V> java.util.concurrent.CompletableFuture<V> supplyAsync(java.util.function.Supplier<V> supplier)

deferTask

public java.util.concurrent.CompletableFuture<java.lang.Void> deferTask(java.lang.Runnable taskIn)

runAsync

public java.util.concurrent.CompletableFuture<java.lang.Void> runAsync(java.lang.Runnable taskIn)

runImmediately

public void runImmediately(java.lang.Runnable taskIn)

enqueue

public void enqueue(R taskIn)

Specified by:

enqueue in interface ITaskExecutor<R extends java.lang.Runnable>

execute

public void execute(java.lang.Runnable p_execute_1_)

Specified by:

execute in interface java.util.concurrent.Executor

dropTasks

protected void dropTasks()

drainTasks

protected void drainTasks()

driveOne

protected boolean driveOne()

driveUntil

public void driveUntil(java.util.function.BooleanSupplier isDone)

threadYieldPark

protected void threadYieldPark()

run

protected void run(R taskIn)