groovyx.gpars.extra166y

Class PAS.FJRemoveAllDriver

java.lang.Object

java.util.concurrent.ForkJoinTask<java.lang.Void>

java.util.concurrent.RecursiveAction

groovyx.gpars.extra166y.PAS.FJRemoveAllDriver

All Implemented Interfaces:

java.io.Serializable, java.util.concurrent.Future<java.lang.Void>

Enclosing class:

PAS

static final class PAS.FJRemoveAllDriver
extends java.util.concurrent.RecursiveAction

Root node for FJRemoveAll. Spawns subtasks and shifts elements as indices become available, bypassing index array creation when offsets are known. This differs from SelectAll mainly in that data movement is all done by the driver rather than in a second parallel pass.

Field Summary

Fields

Modifier and Type	Field and Description
(package private) int	hi
(package private) int[]	indices
(package private) int	lo
(package private) int	offset
(package private) AbstractParallelAnyArray	pap
(package private) int	threshold

Constructor Summary

Constructors

Constructor and Description
FJRemoveAllDriver(AbstractParallelAnyArray pap, int lo, int hi)

Method Summary

Modifier and Type	Method and Description
void	compute()
(package private) static int	inorderMove(PAS.FJRemoveAll t, int index) Inorder traversal to move indexed elements across reachable nodes.

Methods inherited from class java.util.concurrent.RecursiveAction

exec, getRawResult, setRawResult

Methods inherited from class java.util.concurrent.ForkJoinTask

adapt, adapt, adapt, cancel, compareAndSetForkJoinTaskTag, complete, completeExceptionally, fork, get, get, getException, getForkJoinTaskTag, getPool, getQueuedTaskCount, getSurplusQueuedTaskCount, helpQuiesce, inForkJoinPool, invoke, invokeAll, invokeAll, invokeAll, isCancelled, isCompletedAbnormally, isCompletedNormally, isDone, join, peekNextLocalTask, pollNextLocalTask, pollTask, quietlyComplete, quietlyInvoke, quietlyJoin, reinitialize, setForkJoinTaskTag, tryUnfork

Methods inherited from class java.lang.Object

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

Field Detail

pap

final AbstractParallelAnyArray pap

lo

final int lo

hi

final int hi

indices

final int[] indices

offset

int offset

threshold

final int threshold

Constructor Detail

FJRemoveAllDriver

FJRemoveAllDriver(AbstractParallelAnyArray pap,
                  int lo,
                  int hi)

Method Detail

compute

public void compute()

Specified by:

compute in class java.util.concurrent.RecursiveAction

inorderMove

static int inorderMove(PAS.FJRemoveAll t,
                       int index)

Inorder traversal to move indexed elements across reachable nodes. This guarantees that element shifts don't overwrite those still being used by active subtasks.