Class ExternalProcessExecutor.ProcessTask<T>

java.lang.Object

org.ojalgo.concurrent.ExternalProcessExecutor.ProcessTask<T>

All Implemented Interfaces:

Runnable, Future<T>

Enclosing class:

ExternalProcessExecutor

private static final class ExternalProcessExecutor.ProcessTask<T>
extends Object
implements Future<T>, Runnable

Nested Class Summary

Nested classes/interfaces inherited from interface Future

Future.State

Field Summary

Fields

Modifier and Type	Field	Description
private final Object[]	myArguments
private final AtomicBoolean	myCancelled
private final AtomicBoolean	myDone
private Throwable	myError
private final Object	myLock
private final MethodDescriptor	myMethod
private final ProcessOptions	myOptions
private T	myResult
private ExternalProcessExecutor.WorkerChannel	myWorker
private static final ThreadLocal<ExternalProcessExecutor.WorkerChannel>	WORKER

Constructor Summary

Constructors

Constructor	Description
ProcessTask(MethodDescriptor spec, Object[] args, ProcessOptions opts)

Method Summary

Modifier and Type	Method	Description
boolean	cancel(boolean mayInterruptIfRunning)
private static ExternalProcessExecutor.WorkerChannel	ensureWorker(ProcessOptions opts)
T	get()
T	get(long timeout, TimeUnit unit)
boolean	isCancelled()
boolean	isDone()
void	run()
private static boolean	sameOptions(ProcessOptions opt1, ProcessOptions opt2)
(package private) ExternalProcessExecutor.ProcessTask<T>	start(ExecutorService executor)

Methods inherited from class Object

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

Methods inherited from interface Future

exceptionNow, resultNow, state

Field Details

WORKER

private static final ThreadLocal<ExternalProcessExecutor.WorkerChannel> WORKER

myArguments

private final Object[] myArguments

myCancelled

private final AtomicBoolean myCancelled

myDone

private final AtomicBoolean myDone

myError

private volatile Throwable myError

myLock

private final Object myLock

myMethod

private final MethodDescriptor myMethod

myOptions

private final ProcessOptions myOptions

myResult

private volatile T myResult

myWorker

private volatile ExternalProcessExecutor.WorkerChannel myWorker

Constructor Details

ProcessTask

ProcessTask(MethodDescriptor spec,
 Object[] args,
 ProcessOptions opts)

Method Details

ensureWorker

private static ExternalProcessExecutor.WorkerChannel ensureWorker(ProcessOptions opts)
                                                           throws Exception

Throws:

Exception

sameOptions

private static boolean sameOptions(ProcessOptions opt1,
 ProcessOptions opt2)

cancel

public boolean cancel(boolean mayInterruptIfRunning)

Specified by:

cancel in interface Future<T>

get

public T get()
      throws InterruptedException,
ExecutionException

Specified by:

get in interface Future<T>

Throws:

InterruptedException

ExecutionException

get

public T get(long timeout,
 TimeUnit unit)
      throws InterruptedException,
ExecutionException,
TimeoutException

Specified by:

get in interface Future<T>

Throws:

InterruptedException

ExecutionException

TimeoutException

isCancelled

public boolean isCancelled()

Specified by:

isCancelled in interface Future<T>

isDone

public boolean isDone()

Specified by:

isDone in interface Future<T>

run

public void run()

Specified by:

run in interface Runnable

start

ExternalProcessExecutor.ProcessTask<T> start(ExecutorService executor)