com.orientechnologies.common.concur.executors

Class SubExecutorService.CallableTask<V>

java.lang.Object

com.orientechnologies.common.concur.executors.SubExecutorService.CallableTask<V>

All Implemented Interfaces:

SubExecutorService.Task<V>, Runnable, Callable<V>, Future<V>

Enclosing class:

SubExecutorService

protected class SubExecutorService.CallableTask<V>
extends Object
implements SubExecutorService.Task<V>

Constructor Summary

Constructors

Constructor and Description
CallableTask(Callable callable, boolean unregister)

Method Summary

Modifier and Type	Method and Description
void	acquireExecution()
V	call()
boolean	cancel(boolean mayInterruptIfRunning)
V	get()
V	get(long timeout, TimeUnit unit)
Future<V>	getFuture()
boolean	isCancelled()
boolean	isDone()
void	releaseExecution()
void	run()
void	setFuture(Future<V> future)

Methods inherited from class java.lang.Object

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

Constructor Detail

CallableTask

public CallableTask(Callable callable,
                    boolean unregister)

Method Detail

getFuture

public Future<V> getFuture()

Specified by:

getFuture in interface SubExecutorService.Task<V>

setFuture

public void setFuture(Future<V> future)

Specified by:

setFuture in interface SubExecutorService.Task<V>

acquireExecution

public void acquireExecution()

Specified by:

acquireExecution in interface SubExecutorService.Task<V>

releaseExecution

public void releaseExecution()

Specified by:

releaseExecution in interface SubExecutorService.Task<V>

run

public void run()

Specified by:

run in interface Runnable

call

public V call()
       throws Exception

Specified by:

call in interface Callable<V>

Throws:

Exception

cancel

public boolean cancel(boolean mayInterruptIfRunning)

Specified by:

cancel in interface Future<V>

isCancelled

public boolean isCancelled()

Specified by:

isCancelled in interface Future<V>

isDone

public boolean isDone()

Specified by:

isDone in interface Future<V>

get

public V get()
      throws InterruptedException,
             ExecutionException

Specified by:

get in interface Future<V>

Throws:

InterruptedException

ExecutionException

get

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

Specified by:

get in interface Future<V>

Throws:

InterruptedException

ExecutionException

TimeoutException