Class ParallelTask<D extends IntConsumer>

java.lang.Object

java.util.concurrent.ForkJoinTask<Void>

java.util.concurrent.CountedCompleter<Void>

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

All Implemented Interfaces:

Serializable, Future<Void>

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

See Also:

• Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface Future

Future.State

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
ParallelRangeTask<D>	appendTask()
void	compute()
void	doInvoke()
ParallelRangeTask<D>	get(int i)
void	init()
void	reinitialize()
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

Constructor Details

ParallelTask

public ParallelTask(Supplier<D> supplier)

ParallelTask

public ParallelTask(CountedCompleter<?> completer,
 Supplier<D> supplier)

Method Details

reinitialize

public void reinitialize()

Overrides:

reinitialize in class ForkJoinTask<Void>

init

public void init()

appendTask

public ParallelRangeTask<D> appendTask()

size

public int size()

get

public ParallelRangeTask<D> get(int i)

compute

public void compute()

Specified by:

compute in class CountedCompleter<Void>

doInvoke

public void doInvoke()