Class ParallelRangeTask<D extends IntConsumer>

java.lang.Object

java.util.concurrent.ForkJoinTask<Void>

java.util.concurrent.CountedCompleter<Void>

com.hypixel.hytale.component.task.ParallelRangeTask<D>

All Implemented Interfaces:

Serializable, Future<Void>

public class ParallelRangeTask<D extends IntConsumer>
extends CountedCompleter<Void>

See Also:

• Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface Future

Future.State

Field Summary

Fields

Modifier and Type	Field	Description
static final int	PARALLELISM
boolean	running
static final int	TASK_COUNT

Constructor Summary

Constructors

Constructor	Description
ParallelRangeTask(CountedCompleter<?> completer, Supplier<D> supplier)
ParallelRangeTask(Supplier<D> supplier)

Method Summary

Modifier and Type	Method	Description
void	compute()
D	get(int i)
ParallelRangeTask<D>	init(int from, int to)
void	reinitialize()
void	set(int i, D data)
int	size()

Methods inherited from class CountedCompleter

addToPendingCount, compareAndSetPendingCount, complete, decrementPendingCountUnlessZero, firstComplete, getCompleter, getPendingCount, getRawResult, getRoot, helpComplete, nextComplete, onCompletion, onExceptionalCompletion, propagateCompletion, quietlyCompleteRoot, setPendingCount, tryComplete

Methods inherited from class ForkJoinTask

adapt, adapt, adapt, adaptInterruptible, adaptInterruptible, adaptInterruptible, cancel, compareAndSetForkJoinTaskTag, completeExceptionally, exceptionNow, fork, get, get, getException, getForkJoinTaskTag, getPool, getQueuedTaskCount, getSurplusQueuedTaskCount, helpQuiesce, inForkJoinPool, invoke, invokeAll, invokeAll, invokeAll, isCancelled, isCompletedAbnormally, isCompletedNormally, isDone, join, quietlyComplete, quietlyInvoke, quietlyJoin, quietlyJoin, quietlyJoinUninterruptibly, resultNow, setForkJoinTaskTag, state, tryUnfork

Methods inherited from class Object

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

Field Details

PARALLELISM

public static final int PARALLELISM

TASK_COUNT

public static final int TASK_COUNT

running

public volatile boolean running

Constructor Details

ParallelRangeTask

public ParallelRangeTask(@Nonnull
 Supplier<D> supplier)

ParallelRangeTask

public ParallelRangeTask(CountedCompleter<?> completer,
 @Nonnull
 Supplier<D> supplier)

Method Details

reinitialize

public void reinitialize()

Overrides:

reinitialize in class ForkJoinTask<Void>

init

@Nonnull
public ParallelRangeTask<D> init(int from,
 int to)

size

public int size()

get

public D get(int i)

set

public void set(int i,
 D data)

compute

public void compute()

Specified by:

compute in class CountedCompleter<Void>