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> operation, int containerSize, int numBatches)

Method Summary

Modifier and Type	Method	Description
protected abstract int	batchSize(int batchIndex)
private int	pendingBatchSize()
protected abstract CompletableFuture<?>	scheduleBatch(ParallelMapTransform.Container<K,U,V> container, int lastScheduledIndex, int currentIndex, Executor executor)
protected abstract CompletableFuture<Map<K,V>>	scheduleFinalOperation(CompletableFuture<?> future, ParallelMapTransform.Container<K,U,V> container)
CompletableFuture<Map<K,V>>	scheduleTasks(Map<K,U> inputs, Executor executor)

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> operation,
 int containerSize,
 int numBatches)

Method Details

pendingBatchSize

private int pendingBatchSize()

scheduleTasks

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

batchSize

protected abstract int batchSize(int batchIndex)

scheduleBatch

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

scheduleFinalOperation

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