Package com.hypixel.hytale.component.task

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 java.util.concurrent.Future

Future.State

Field Summary

Fields

Modifier and Type	Field	Description
private boolean	running
private int	size
private ParallelRangeTask<D>[]	subTasks
private final Supplier<D>	supplier

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 java.util.concurrent.CountedCompleter

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

Methods inherited from class java.util.concurrent.ForkJoinTask

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

Methods inherited from class java.lang.Object

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

Field Details

supplier

private final Supplier<D extends IntConsumer> supplier

subTasks

@Nonnull
private ParallelRangeTask<D extends IntConsumer>[] subTasks

size

private int size

running

private volatile boolean running

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()