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> p_405196_, int p_405517_, int p_405788_)

Method Summary

Modifier and Type	Method	Description
protected abstract int	batchSize(int p_405377_)
private int	pendingBatchSize()
protected abstract CompletableFuture<?>	scheduleBatch(ParallelMapTransform.Container<K,U,V> p_405692_, int p_404873_, int p_405552_, Executor p_405568_)
protected abstract CompletableFuture<Map<K,V>>	scheduleFinalOperation(CompletableFuture<?> p_405448_, ParallelMapTransform.Container<K,U,V> p_405155_)
CompletableFuture<Map<K,V>>	scheduleTasks(Map<K,U> p_405332_, Executor p_405350_)

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> p_405196_,
 int p_405517_,
 int p_405788_)

Method Details

pendingBatchSize

private int pendingBatchSize()

scheduleTasks

public CompletableFuture<Map<K,V>> scheduleTasks(Map<K,U> p_405332_,
 Executor p_405350_)

batchSize

protected abstract int batchSize(int p_405377_)

scheduleBatch

protected abstract CompletableFuture<?> scheduleBatch(ParallelMapTransform.Container<K,U,V> p_405692_,
 int p_404873_,
 int p_405552_,
 Executor p_405568_)

scheduleFinalOperation

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