Package net.minecraftforge.fml

Class DeferredWorkQueue

java.lang.Object

net.minecraftforge.fml.DeferredWorkQueue

public class DeferredWorkQueue
extends Object

Utility for running code on the main launch thread at the next available opportunity. There is no guaranteed order that work from various mods will be run, but your own work will be run sequentially.

Use of this class after startup is not possible. At that point, ReentrantBlockableEventLoop should be used instead.

Exceptions from tasks will be handled gracefully, causing a mod loading error. Tasks that take egregiously long times to run will be logged.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static class	DeferredWorkQueue.TaskInfo

Field Summary

Fields

Modifier and Type	Field	Description
private static final org.apache.logging.log4j.Logger	LOGGER
private final ModLoadingStage	modLoadingStage
private final ConcurrentLinkedDeque<DeferredWorkQueue.TaskInfo>	tasks
private static final Map<ModLoadingStage,DeferredWorkQueue>	workQueues

Constructor Summary

Constructors

Constructor	Description
DeferredWorkQueue(ModLoadingStage modLoadingStage)

Method Summary

Modifier and Type	Method	Description
private static <T> T	captureException(String modId, RuntimeException aggregate, Throwable throwable)
CompletableFuture<Void>	enqueueWork(ModContainer modInfo, Runnable work)
private <T> CompletableFuture<T>	enqueueWork(ModContainer modInfo, Function<DeferredWorkQueue.TaskInfo,CompletableFuture<T>> futureGen)
<T> CompletableFuture<T>	enqueueWork(ModContainer modInfo, Supplier<T> work)
static Optional<DeferredWorkQueue>	lookup(Optional<ModLoadingStage> parallelClass)
private static void	makeRunnable(DeferredWorkQueue.TaskInfo ti, Executor executor, RuntimeException aggregate)
void	runTasks()

Methods inherited from class java.lang.Object

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

Field Details

LOGGER

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

workQueues

private static final Map<ModLoadingStage,DeferredWorkQueue> workQueues

tasks

private final ConcurrentLinkedDeque<DeferredWorkQueue.TaskInfo> tasks

modLoadingStage

private final ModLoadingStage modLoadingStage

Constructor Details

DeferredWorkQueue

public DeferredWorkQueue(ModLoadingStage modLoadingStage)

Method Details

lookup

public static Optional<DeferredWorkQueue> lookup(Optional<ModLoadingStage> parallelClass)

runTasks

public void runTasks()

makeRunnable

private static void makeRunnable(DeferredWorkQueue.TaskInfo ti,
 Executor executor,
 RuntimeException aggregate)

captureException

private static <T> T captureException(String modId,
 RuntimeException aggregate,
 Throwable throwable)

enqueueWork

public CompletableFuture<Void> enqueueWork(ModContainer modInfo,
 Runnable work)

enqueueWork

public <T> CompletableFuture<T> enqueueWork(ModContainer modInfo,
 Supplier<T> work)

enqueueWork

private <T> CompletableFuture<T> enqueueWork(ModContainer modInfo,
 Function<DeferredWorkQueue.TaskInfo,CompletableFuture<T>> futureGen)