Overview  Package   Class  Deprecated  Index  Help 
org.codehaus.gpars
FRAMES    NO FRAMES    
SUMMARY: NESTED | FIELD | CONSTR | METHOD DETAIL: FIELD | CONSTR | METHOD

groovyx.gpars.forkjoin
[Java] Class FJWorker

java.lang.Object
  jsr166y.ForkJoinTask
      jsr166y.RecursiveTask
          groovyx.gpars.forkjoin.AbstractForkJoinWorker
              groovyx.gpars.forkjoin.FJWorker

@SuppressWarnings({"unchecked"})
final class FJWorker
extends AbstractForkJoinWorker

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

Authors:
Vaclav Pech

Field Summary
static Object[] EMPTY_OBJECTS

private T[] args

private groovy.lang.Closure code

 
Fields inherited from class AbstractForkJoinWorker
children
 
Constructor Summary
FJWorker(java.lang.Object args)

 
Method Summary
protected T computeTask()

void forkOffChild(java.lang.Object childArgs)

T runChildDirectly(java.lang.Object childArgs)

 
Methods inherited from class AbstractForkJoinWorker
compute, computeTask, forkOffChild, getChildrenResults
 
Methods inherited from class jsr166y.RecursiveTask
jsr166y.RecursiveTask#getRawResult(), jsr166y.RecursiveTask#invoke(), jsr166y.RecursiveTask#get(), jsr166y.RecursiveTask#get(long, java.util.concurrent.TimeUnit), jsr166y.RecursiveTask#getException(), jsr166y.RecursiveTask#join(), jsr166y.RecursiveTask#complete(java.lang.Object), jsr166y.RecursiveTask#getPool(), jsr166y.RecursiveTask#cancel(boolean), jsr166y.RecursiveTask#fork(), jsr166y.RecursiveTask#isCancelled(), jsr166y.RecursiveTask#invokeAll(jsr166y.ForkJoinTask, jsr166y.ForkJoinTask), jsr166y.RecursiveTask#invokeAll([Ljsr166y.ForkJoinTask;), jsr166y.RecursiveTask#invokeAll(java.util.Collection), jsr166y.RecursiveTask#isDone(), jsr166y.RecursiveTask#isCompletedAbnormally(), jsr166y.RecursiveTask#isCompletedNormally(), jsr166y.RecursiveTask#completeExceptionally(java.lang.Throwable), jsr166y.RecursiveTask#quietlyJoin(), jsr166y.RecursiveTask#quietlyInvoke(), jsr166y.RecursiveTask#helpQuiesce(), jsr166y.RecursiveTask#reinitialize(), jsr166y.RecursiveTask#inForkJoinPool(), jsr166y.RecursiveTask#tryUnfork(), jsr166y.RecursiveTask#getQueuedTaskCount(), jsr166y.RecursiveTask#getSurplusQueuedTaskCount(), jsr166y.RecursiveTask#adapt(java.lang.Runnable, java.lang.Object), jsr166y.RecursiveTask#adapt(java.lang.Runnable), jsr166y.RecursiveTask#adapt(java.util.concurrent.Callable), jsr166y.RecursiveTask#wait(long), jsr166y.RecursiveTask#wait(), jsr166y.RecursiveTask#wait(long, int), jsr166y.RecursiveTask#equals(java.lang.Object), jsr166y.RecursiveTask#toString(), jsr166y.RecursiveTask#hashCode(), jsr166y.RecursiveTask#getClass(), jsr166y.RecursiveTask#notify(), jsr166y.RecursiveTask#notifyAll()
 
Methods inherited from class jsr166y.ForkJoinTask
jsr166y.ForkJoinTask#invoke(), jsr166y.ForkJoinTask#get(), jsr166y.ForkJoinTask#get(long, java.util.concurrent.TimeUnit), jsr166y.ForkJoinTask#getException(), jsr166y.ForkJoinTask#join(), jsr166y.ForkJoinTask#complete(java.lang.Object), jsr166y.ForkJoinTask#getPool(), jsr166y.ForkJoinTask#cancel(boolean), jsr166y.ForkJoinTask#fork(), jsr166y.ForkJoinTask#isCancelled(), jsr166y.ForkJoinTask#invokeAll(jsr166y.ForkJoinTask, jsr166y.ForkJoinTask), jsr166y.ForkJoinTask#invokeAll([Ljsr166y.ForkJoinTask;), jsr166y.ForkJoinTask#invokeAll(java.util.Collection), jsr166y.ForkJoinTask#isDone(), jsr166y.ForkJoinTask#getRawResult(), jsr166y.ForkJoinTask#isCompletedAbnormally(), jsr166y.ForkJoinTask#isCompletedNormally(), jsr166y.ForkJoinTask#completeExceptionally(java.lang.Throwable), jsr166y.ForkJoinTask#quietlyJoin(), jsr166y.ForkJoinTask#quietlyInvoke(), jsr166y.ForkJoinTask#helpQuiesce(), jsr166y.ForkJoinTask#reinitialize(), jsr166y.ForkJoinTask#inForkJoinPool(), jsr166y.ForkJoinTask#tryUnfork(), jsr166y.ForkJoinTask#getQueuedTaskCount(), jsr166y.ForkJoinTask#getSurplusQueuedTaskCount(), jsr166y.ForkJoinTask#adapt(java.lang.Runnable, java.lang.Object), jsr166y.ForkJoinTask#adapt(java.lang.Runnable), jsr166y.ForkJoinTask#adapt(java.util.concurrent.Callable), jsr166y.ForkJoinTask#wait(long), jsr166y.ForkJoinTask#wait(), jsr166y.ForkJoinTask#wait(long, int), jsr166y.ForkJoinTask#equals(java.lang.Object), jsr166y.ForkJoinTask#toString(), jsr166y.ForkJoinTask#hashCode(), jsr166y.ForkJoinTask#getClass(), jsr166y.ForkJoinTask#notify(), jsr166y.ForkJoinTask#notifyAll()
 
Methods inherited from class java.lang.Object
java.lang.Object#wait(long), java.lang.Object#wait(), java.lang.Object#wait(long, int), java.lang.Object#equals(java.lang.Object), java.lang.Object#toString(), java.lang.Object#hashCode(), java.lang.Object#getClass(), java.lang.Object#notify(), java.lang.Object#notifyAll()
 

Field Detail

EMPTY_OBJECTS

public static final Object[] EMPTY_OBJECTS

args

private final T[] args

code

private final groovy.lang.Closure code

 
Constructor Detail

FJWorker

FJWorker(java.lang.Object args)

 
Method Detail

computeTask

@Override
protected T computeTask()

forkOffChild

@SuppressWarnings({"MethodOverloadsMethodOfSuperclass", "OverloadedVarargsMethod"})
void forkOffChild(java.lang.Object childArgs)

runChildDirectly

@SuppressWarnings({"MethodOverloadsMethodOfSuperclass", "OverloadedVarargsMethod"})
T runChildDirectly(java.lang.Object childArgs)

 

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