org.teiid.dqp.internal.process

Class FutureWork<T>

java.lang.Object

java.util.concurrent.FutureTask<T>

org.teiid.dqp.internal.process.FutureWork<T>

All Implemented Interfaces:

Runnable, Future<T>, RunnableFuture<T>, javax.resource.spi.work.Work, ThreadReuseExecutor.PrioritizedRunnable

public final class FutureWork<T>
extends FutureTask<T>
implements ThreadReuseExecutor.PrioritizedRunnable, javax.resource.spi.work.Work

Field Summary

Fields inherited from interface org.teiid.dqp.internal.process.ThreadReuseExecutor.PrioritizedRunnable

NO_WAIT_PRIORITY

Constructor Summary

Constructors

Constructor and Description
FutureWork(Callable<T> processor, int priority)
FutureWork(Runnable processor, T result, int priority)

Method Summary

Modifier and Type	Method and Description
protected void	done()
long	getCreationTime()
DQPWorkContext	getDqpWorkContext()
int	getPriority()
void	release()
void	run()
void	setRequestId(String requestId)

Methods inherited from class java.util.concurrent.FutureTask

cancel, get, get, isCancelled, isDone, runAndReset, set, setException

Methods inherited from class java.lang.Object

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

Constructor Detail

FutureWork

public FutureWork(Callable<T> processor,
                  int priority)

FutureWork

public FutureWork(Runnable processor,
                  T result,
                  int priority)

Method Detail

setRequestId

public void setRequestId(String requestId)

run

public void run()

Specified by:

run in interface Runnable

Specified by:

run in interface RunnableFuture<T>

Overrides:

run in class FutureTask<T>

getPriority

public int getPriority()

Specified by:

getPriority in interface ThreadReuseExecutor.PrioritizedRunnable

getCreationTime

public long getCreationTime()

Specified by:

getCreationTime in interface ThreadReuseExecutor.PrioritizedRunnable

getDqpWorkContext

public DQPWorkContext getDqpWorkContext()

Specified by:

getDqpWorkContext in interface ThreadReuseExecutor.PrioritizedRunnable

release

public void release()

Specified by:

release in interface javax.resource.spi.work.Work

done

protected void done()

Overrides:

done in class FutureTask<T>