Class ParallelMapTransform.SplitterBase<K,U,V>

java.lang.Object

net.minecraft.util.thread.ParallelMapTransform.SplitterBase<K,U,V>

Direct Known Subclasses:

ParallelMapTransform.BatchedTaskSplitter, ParallelMapTransform.SingleTaskSplitter

Enclosing class:

ParallelMapTransform

private abstract static class ParallelMapTransform.SplitterBase<K,U,V>
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private int	batchIndex
private final ParallelMapTransform.Container<K,U,V>	container
private int	currentIndex
private int	lastScheduledIndex
private final CompletableFuture<?>[]	tasks

Constructor Summary

Constructors

Modifier	Constructor	Description
private	SplitterBase(BiFunction<K,U,V> operation, int size, int taskCount)

Method Summary

Modifier and Type	Method	Description
protected abstract int	batchSize(int index)
private int	pendingBatchSize()
protected abstract CompletableFuture<?>	scheduleBatch(ParallelMapTransform.Container<K,U,V> container, int startIndex, int endIndex, Executor executor)
protected abstract CompletableFuture<Map<K,V>>	scheduleFinalOperation(CompletableFuture<?> allTasksDone, ParallelMapTransform.Container<K,U,V> container)
CompletableFuture<Map<K,V>>	scheduleTasks(Map<K,U> input, Executor executor)

Methods inherited from class Object

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

Field Details

lastScheduledIndex

private int lastScheduledIndex

currentIndex

private int currentIndex

tasks

private final CompletableFuture<?>[] tasks

batchIndex

private int batchIndex

container

private final ParallelMapTransform.Container<K,U,V> container

Constructor Details

SplitterBase

private SplitterBase(BiFunction<K,U,V> operation,
 int size,
 int taskCount)

Method Details

pendingBatchSize

private int pendingBatchSize()

scheduleTasks

public CompletableFuture<Map<K,V>> scheduleTasks(Map<K,U> input,
 Executor executor)

batchSize

protected abstract int batchSize(int index)

scheduleBatch

protected abstract CompletableFuture<?> scheduleBatch(ParallelMapTransform.Container<K,U,V> container,
 int startIndex,
 int endIndex,
 Executor executor)

scheduleFinalOperation

protected abstract CompletableFuture<Map<K,V>> scheduleFinalOperation(CompletableFuture<?> allTasksDone,
 ParallelMapTransform.Container<K,U,V> container)