groovyx.gpars.forkjoin
Class FJWorker<T>

java.lang.Object
  extended by jsr166y.ForkJoinTask<V>
      extended by jsr166y.RecursiveTask<T>
          extended by groovyx.gpars.forkjoin.AbstractForkJoinWorker<T>
              extended by 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>

Copyright © 2008–2012 Václav Pech. All Rights Reserved.