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, SoundEngineExecutor

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

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_)
int	func_223704_be()
protected void	func_223705_bi()
protected abstract java.lang.Thread	getExecutionThread()
java.lang.String	getName()
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 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

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()

func_223704_be

public int func_223704_be()

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)

func_223705_bi

protected void func_223705_bi()

run

protected void run(R taskIn)