net.minecraft.util.thread

public abstract class ThreadExecutor<R extends Runnable>

implements Executor, TaskExecutor<R>, SampleableExecutor

net.minecraft.util.thread.BlockableEventLoop
net.minecraft.util.thread.BlockableEventLoop
net.minecraft.class_1255
net.minecraft.util.thread.ThreadExecutor

Field summary

Modifier and TypeField
public static final long
BLOCK_TIME_NANOS
BLOCK_TIME_NANOS
field_52421
WAIT_TIMEOUT_NS
private static volatile Supplier<CrashReport>
delayedCrash
delayedCrash
field_1_1838
crashReportSupplier
private final boolean
propagatesCrashes
propagatesCrashes
field_1_1839
throwOnCrashReport
private final String
name
name
field_18318
name
private static final org.slf4j.Logger
LOGGER
LOGGER
field_5751
LOGGER
private final Queue<R>
pendingRunnables
pendingRunnables
field_5750
tasks
private int
blockingCount
blockingCount
field_18319
executionsInProgress

Constructor summary

ModifierConstructor
protected (String name, boolean throwOnCrashReport)

Method summary

Modifier and TypeMethod
protected abstract boolean
shouldRun(R task)
shouldRun(R task)
method_18856(R arg0)
canExecute(R task)
public boolean
isSameThread()
isSameThread()
method_18854()
isOnThread()
protected abstract Thread
getRunningThread()
getRunningThread()
method_3777()
getThread()
protected boolean
scheduleExecutables()
scheduleExecutables()
method_5384()
shouldExecuteAsync()
public int
getPendingTasksCount()
getPendingTasksCount()
method_21684()
getTaskCount()
public String
name()
name()
method_16898()
getName()
public <V> CompletableFuture<V>
submit(Supplier<V> supplier)
submit(Supplier<V> supplier)
method_5385(Supplier<V> arg0)
submit(Supplier<V> task)
private CompletableFuture<Void>
submitAsync(Runnable runnable)
submitAsync(Runnable runnable)
method_5382(Runnable arg0)
submitAsync(Runnable runnable)
public CompletableFuture<Void>
submit(Runnable runnable)
submit(Runnable runnable)
method_20493(Runnable arg0)
submit(Runnable task)
public void
executeBlocking(Runnable runnable)
executeBlocking(Runnable runnable)
method_19537(Runnable arg0)
submitAndJoin(Runnable runnable)
public void
schedule(R r)
schedule(R r)
method_63588(R arg0)
send(R arg0)
public void
execute(Runnable command)
execute(Runnable command)
execute(Runnable arg0)
execute(Runnable runnable)
public void
executeIfPossible(Runnable command)
executeIfPossible(Runnable command)
method_40000(Runnable arg0)
executeSync(Runnable runnable)
protected void
dropAllTasks()
dropAllTasks()
method_18855()
cancelTasks()
protected void
runAllTasks()
runAllTasks()
method_5383()
runTasks()
protected boolean
shouldRunAllTasks()
shouldRunAllTasks()
method_72378()
isExecutionInProgress()
protected boolean
pollTask()
pollTask()
method_16075()
runTask()
public void
managedBlock(BooleanSupplier condition)
managedBlock(BooleanSupplier condition)
method_18857(BooleanSupplier arg0)
runTasks(BooleanSupplier stopCondition)
protected void
waitForTasks()
waitForTasks()
method_20813()
waitForTasks()
protected void
doRunTask(R task)
doRunTask(R task)
method_18859(R arg0)
executeTask(R task)
public List<Sampler>
profiledMetrics()
profiledMetrics()
method_34705()
createSamplers()
public static boolean
isNonRecoverable(Throwable t)
isNonRecoverable(Throwable t)
method_61391(Throwable arg0)
isMemoryError(Throwable exception)
private void
throwDelayedException()
throwDelayedException()
method_1_2250()
checkForCrashReport()
protected boolean
hasDelayedCrash()
hasDelayedCrash()
method_1_2246()
hasCrashReport()
public void
delayCrash(CrashReport crashReport)
delayCrash(CrashReport crashReport)
method_1494(class_128 arg0)
setCrashReport(CrashReport crashReport)
public static synchronized void
relayDelayCrash(CrashReport crashReport)
relayDelayCrash(CrashReport crashReport)
method_1_2249(class_128 arg0)
addCrashReport(CrashReport crashReport)