net.minecraft.util.thread

abstract class AsyncHelper$Batcher<K, U, V>

net.minecraft.util.thread.ParallelMapTransform$SplitterBase
net.minecraft.class_10769$class_10773
net.minecraft.util.thread.AsyncHelper$Batcher

Field summary

Modifier and TypeField
private int
lastScheduledIndex
field_56622
lastBatch
private int
currentIndex
field_56624
index
private final CompletableFuture<?>[]
tasks
field_56625
futures
private int
batchIndex
field_56626
batch
private final AsyncHelper$Future<K, U, V>
container
field_56627
entry
static final boolean
$assertionsDisabled
field_56623
field_56623

Constructor summary

ModifierConstructor
private (BiFunction<K, U, V> function, int size, int startAt)

Method summary

Modifier and TypeMethod
private int
pendingBatchSize()
method_67629()
nextSize()
public CompletableFuture<Map<K, V>>
scheduleTasks(Map<K, U> input, Executor executor)
method_67630(Map<K, U> arg0, Executor arg1)
mapAsync(Map<K, U> future, Executor executor)
protected abstract int
batchSize(int index)
method_67614(int arg0)
getLastIndex(int batch)
protected abstract CompletableFuture<?>
scheduleBatch(ParallelMapTransform$Container<K, U, V> container, int startIndex, int endIndex, Executor executor)
method_67616(class_10769$class_10771<K, U, V> arg0, int arg1, int arg2, Executor arg3)
newBatch(AsyncHelper$Future<K, U, V> futures, int size, int maxCount, Executor executor)
protected abstract CompletableFuture<Map<K, V>>
scheduleFinalOperation(CompletableFuture<?> allTasksDone, ParallelMapTransform$Container<K, U, V> container)
method_67619(CompletableFuture<?> arg0, class_10769$class_10771<K, U, V> arg1)
addLastTask(CompletableFuture<?> future, AsyncHelper$Future<K, U, V> entry)
private void
lambda$scheduleTasks$0(Executor arg0, Object arg1, Object arg2)
method_67631(Executor arg0, Object arg1, Object arg2)
method_67631(Executor arg0, Object key, Object value)