groovyx.gpars.forkjoin

Class FJWorker<T>

java.lang.Object

java.util.concurrent.ForkJoinTask<V>

java.util.concurrent.RecursiveTask<T>

groovyx.gpars.forkjoin.AbstractForkJoinWorker<T>

groovyx.gpars.forkjoin.FJWorker<T>

All Implemented Interfaces:

java.io.Serializable, java.util.concurrent.Future<T>

final class FJWorker<T>
extends AbstractForkJoinWorker<T>

Represents a recursive task for the builder-style fork/join algorithm.

Author:

Vaclav Pech

Field Summary

Fields

Modifier and Type	Field and Description
private T[]	args
private groovy.lang.Closure	code
static java.lang.Object[]	EMPTY_OBJECTS

Constructor Summary

Constructors

Constructor and Description
FJWorker(java.lang.Object... args)

Method Summary

Modifier and Type	Method and Description
protected T	computeTask()
(package private) void	forkOffChild(java.lang.Object... childArgs)
(package private) T	runChildDirectly(java.lang.Object... childArgs)

Methods inherited from class groovyx.gpars.forkjoin.AbstractForkJoinWorker

compute, forkOffChild, getChildrenResults

Methods inherited from class java.util.concurrent.RecursiveTask

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

code

private final groovy.lang.Closure code

args

private final T[] args

EMPTY_OBJECTS

public static final java.lang.Object[] EMPTY_OBJECTS

Constructor Detail

FJWorker

FJWorker(java.lang.Object... args)

Method Detail

forkOffChild

void forkOffChild(java.lang.Object... childArgs)

runChildDirectly

T runChildDirectly(java.lang.Object... childArgs)

computeTask

protected T computeTask()

Specified by:

computeTask in class AbstractForkJoinWorker<T>