groovyx.gpars.forkjoin
Class FJWorker<T>

java.lang.Object
  jsr166y.ForkJoinTask<V>
      jsr166y.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

private T[]	args
private groovy.lang.Closure	code
static java.lang.Object[]	EMPTY_OBJECTS

Constructor Summary

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

Method Summary

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 jsr166y.RecursiveTask

exec, getRawResult, setRawResult

Methods inherited from class jsr166y.ForkJoinTask

adapt, adapt, adapt, cancel, complete, completeExceptionally, fork, get, get, getException, getPool, getQueuedTaskCount, getSurplusQueuedTaskCount, helpQuiesce, inForkJoinPool, invoke, invokeAll, invokeAll, invokeAll, isCancelled, isCompletedAbnormally, isCompletedNormally, isDone, join, peekNextLocalTask, pollNextLocalTask, pollTask, quietlyInvoke, quietlyJoin, reinitialize, 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>