Package net.minecraft.util.thread

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

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

Constructor	Description
SplitterBase(BiFunction<K,U,V> pOperation, int pContainerSize, int pNumBatches)

Method Summary

Modifier and Type	Method	Description
protected abstract int	batchSize(int pBatchIndex)
private int	pendingBatchSize()
protected abstract CompletableFuture<?>	scheduleBatch(ParallelMapTransform.Container<K,U,V> pContainer, int pLastScheduledIndex, int pCurrentIndex, Executor pExecutor)
protected abstract CompletableFuture<Map<K,V>>	scheduleFinalOperation(CompletableFuture<?> pFuture, ParallelMapTransform.Container<K,U,V> pContainer)
CompletableFuture<Map<K,V>>	scheduleTasks(Map<K,U> pInputs, Executor pExecutor)

Methods inherited from class java.lang.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

SplitterBase(BiFunction<K,U,V> pOperation,
 int pContainerSize,
 int pNumBatches)

Method Details

pendingBatchSize

private int pendingBatchSize()

scheduleTasks

public CompletableFuture<Map<K,V>> scheduleTasks(Map<K,U> pInputs,
 Executor pExecutor)

batchSize

protected abstract int batchSize(int pBatchIndex)

scheduleBatch

protected abstract CompletableFuture<?> scheduleBatch(ParallelMapTransform.Container<K,U,V> pContainer,
 int pLastScheduledIndex,
 int pCurrentIndex,
 Executor pExecutor)

scheduleFinalOperation

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