co.paralleluniverse.concurrent.forkjoin

Class ParkableForkJoinTask<V>

java.lang.Object

java.util.concurrent.ForkJoinTask<V>

co.paralleluniverse.concurrent.forkjoin.ParkableForkJoinTask<V>

All Implemented Interfaces:

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

public abstract class ParkableForkJoinTask<V>
extends java.util.concurrent.ForkJoinTask<V>

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ParkableForkJoinTask.Park

Field Summary

Fields

Modifier and Type	Field and Description
static boolean	CAPTURE_UNPARK_STACK
static java.lang.Object	EMERGENCY_UNBLOCKER
static int	LEASED
static ParkableForkJoinTask.Park	PARK
static int	PARKED
static int	PARKING
static FlightRecorder	RECORDER
static int	RUNNABLE

Constructor Summary

Constructors

Constructor and Description
ParkableForkJoinTask()

Method Summary

Modifier and Type	Method and Description
protected void	doPark(boolean yield)
protected boolean	exec()
protected abstract boolean	exec1()
void	fork1()
java.lang.Object	getBlocker()
static ParkableForkJoinTask<?>	getCurrent()
protected int	getState()
static java.lang.Object	getTarget(java.lang.Thread thread)
protected java.lang.Object	getUnparker()
protected java.lang.StackTraceElement[]	getUnparkStackTrace()
protected boolean	isRecording()
protected void	onCompletion(boolean res)
protected void	onException(java.lang.Throwable t)
protected void	onExec()
protected void	onParked(boolean yield)
protected boolean	park(java.lang.Object blocker)
protected boolean	park(java.lang.Object blocker, boolean exclusive)
protected void	parking(boolean yield)
static void	record(java.lang.String method, java.lang.String format)
static void	record(java.lang.String method, java.lang.String format, java.lang.Object arg1)
static void	record(java.lang.String method, java.lang.String format, java.lang.Object arg1, java.lang.Object arg2)
static void	record(java.lang.String method, java.lang.String format, java.lang.Object arg1, java.lang.Object arg2, java.lang.Object arg3)
static void	record(java.lang.String method, java.lang.String format, java.lang.Object arg1, java.lang.Object arg2, java.lang.Object arg3, java.lang.Object arg4)
static void	record(java.lang.String method, java.lang.String format, java.lang.Object arg1, java.lang.Object arg2, java.lang.Object arg3, java.lang.Object arg4, java.lang.Object arg5)
protected void	setState(int state)
static void	setTarget(java.lang.Thread thread, java.lang.Object target)
protected void	submit()
protected void	throwPark(boolean yield)
java.lang.String	toString()
protected boolean	tryUnpark(java.lang.Object unblocker)
boolean	unpark()
boolean	unpark(java.util.concurrent.ForkJoinPool fjPool, java.lang.Object unblocker)
boolean	unpark(java.lang.Object unblocker)
protected void	yield()

Methods inherited from class java.util.concurrent.ForkJoinTask

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

Methods inherited from class java.lang.Object

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

Field Detail

RECORDER

public static final FlightRecorder RECORDER

CAPTURE_UNPARK_STACK

public static final boolean CAPTURE_UNPARK_STACK

EMERGENCY_UNBLOCKER

public static final java.lang.Object EMERGENCY_UNBLOCKER

PARK

public static final ParkableForkJoinTask.Park PARK

RUNNABLE

public static final int RUNNABLE

See Also:

Constant Field Values

LEASED

public static final int LEASED

See Also:

Constant Field Values

PARKED

public static final int PARKED

See Also:

Constant Field Values

PARKING

public static final int PARKING

See Also:

Constant Field Values

Constructor Detail

ParkableForkJoinTask

public ParkableForkJoinTask()

Method Detail

getCurrent

public static ParkableForkJoinTask<?> getCurrent()

exec

protected boolean exec()

Specified by:

exec in class java.util.concurrent.ForkJoinTask<V>

fork1

public final void fork1()

setTarget

public static void setTarget(java.lang.Thread thread,
                             java.lang.Object target)

getTarget

public static java.lang.Object getTarget(java.lang.Thread thread)

exec1

protected abstract boolean exec1()

getBlocker

public java.lang.Object getBlocker()

onExec

protected void onExec()

onCompletion

protected void onCompletion(boolean res)

onException

protected void onException(java.lang.Throwable t)

parking

protected void parking(boolean yield)

onParked

protected void onParked(boolean yield)

getUnparker

protected java.lang.Object getUnparker()

getUnparkStackTrace

protected java.lang.StackTraceElement[] getUnparkStackTrace()

doPark

protected void doPark(boolean yield)

throwPark

protected void throwPark(boolean yield)
                  throws java.lang.Exception

Throws:

java.lang.Exception

park

protected boolean park(java.lang.Object blocker)
                throws java.lang.Exception

Throws:

java.lang.Exception

park

protected boolean park(java.lang.Object blocker,
                       boolean exclusive)
                throws java.lang.Exception

Throws:

java.lang.Exception

unpark

public boolean unpark()

unpark

public boolean unpark(java.lang.Object unblocker)

unpark

public boolean unpark(java.util.concurrent.ForkJoinPool fjPool,
                      java.lang.Object unblocker)

tryUnpark

protected boolean tryUnpark(java.lang.Object unblocker)

yield

protected void yield()
              throws java.lang.Exception

Throws:

java.lang.Exception

submit

protected void submit()

getState

protected int getState()

setState

protected void setState(int state)

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

isRecording

protected boolean isRecording()

record

public static void record(java.lang.String method,
                          java.lang.String format)

record

public static void record(java.lang.String method,
                          java.lang.String format,
                          java.lang.Object arg1)

record

public static void record(java.lang.String method,
                          java.lang.String format,
                          java.lang.Object arg1,
                          java.lang.Object arg2)

record

public static void record(java.lang.String method,
                          java.lang.String format,
                          java.lang.Object arg1,
                          java.lang.Object arg2,
                          java.lang.Object arg3)

record

public static void record(java.lang.String method,
                          java.lang.String format,
                          java.lang.Object arg1,
                          java.lang.Object arg2,
                          java.lang.Object arg3,
                          java.lang.Object arg4)

record

public static void record(java.lang.String method,
                          java.lang.String format,
                          java.lang.Object arg1,
                          java.lang.Object arg2,
                          java.lang.Object arg3,
                          java.lang.Object arg4,
                          java.lang.Object arg5)