Package 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
    Description
    CallableTaskWrapper(Callable<T> callableTask)
    CTOR.

  • Method Summary

    Modifier and Type
    Method
    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