Package com.hypixel.hytale.component.task

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

Modifier and Type	Class	Description
(package private) static class	ParallelRangeTask.SubTask<D extends IntConsumer>

Nested classes/interfaces inherited from interface java.util.concurrent.Future

Future.State

Field Summary

Fields

Modifier and Type	Field	Description
static final int	PARALLELISM
boolean	running
private int	size
private final ParallelRangeTask.SubTask<D>[]	subTasks
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 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

PARALLELISM

public static final int PARALLELISM

TASK_COUNT

public static final int TASK_COUNT

subTasks

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

size

private int size

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>