org.apache.drill.exec.util.concurrent

Class ExecutorServiceUtil.CallableTaskWrapper<T>

java.lang.Object

org.apache.drill.exec.util.concurrent.ExecutorServiceUtil.CallableTaskWrapper<T>

All Implemented Interfaces:

Callable<T>, Future<T>

Enclosing class:

ExecutorServiceUtil

public static final class ExecutorServiceUtil.CallableTaskWrapper<T>
extends Object
implements Callable<T>, Future<T>

Executor task wrapper to enhance task cancellation behavior

Constructor Summary

Constructors

Constructor and Description
CallableTaskWrapper(Callable<T> callableTask) CTOR.

Method Summary

Modifier and Type	Method and Description
T	call()
boolean	cancel(boolean mayInterruptIfRunning) This method will block waiting if the callbale thread is still executing and the "mayInterruptIfRunning" flag is set; this method will return when: The callbale thread is done executing The current thread got interrupted; no exception will be thrown and instead the interrupted flag will be set
T	get()
T	get(long timeout, TimeUnit unit)
boolean	isCancelled()
boolean	isDone()
void	setFuture(Future<T> feature)

Methods inherited from class java.lang.Object

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

Constructor Detail

CallableTaskWrapper

public CallableTaskWrapper(Callable<T> callableTask)

CTOR.

Parameters:

callableTask - original callable task

Method Detail

call

public T call()
       throws Exception

Specified by:

call in interface Callable<T>

Throws:

Exception

cancel

public boolean cancel(boolean mayInterruptIfRunning)

This method will block waiting if the callbale thread is still executing and the "mayInterruptIfRunning" flag is set; this method will return when:

• The callbale thread is done executing
• The current thread got interrupted; no exception will be thrown and instead the interrupted flag will be set

Specified by:

cancel in interface Future<T>

See Also:

Future#cancel(boolean)}

isCancelled

public boolean isCancelled()

Specified by:

isCancelled in interface Future<T>

isDone

public boolean isDone()

Specified by:

isDone in interface Future<T>

Returns:

true if the task has completed execution

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

setFuture

public void setFuture(Future<T> feature)

Parameters:

feature - the feature to set