org.apache.drill.exec.util.concurrent

Class ExecutorServiceUtil

java.lang.Object

org.apache.drill.exec.util.concurrent.ExecutorServiceUtil

public final class ExecutorServiceUtil
extends Object

Utility class to enhance the Java ExecutorService class functionality

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ExecutorServiceUtil.CallableTaskWrapper<T> Executor task wrapper to enhance task cancellation behavior

Method Summary

Modifier and Type	Method and Description
static <T> Future<T>	submit(ExecutorService service, Callable<T> callable) Helper method to submit the callabale task, gets the original future object, and wrap it in another future object with the ability to decorate the Future.cancel(boolean) method; this decorator will block when future cancellation is invoked (and the "mayInterruptIfRunning" parameter is set to true).

Methods inherited from class java.lang.Object

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

Method Detail

submit

public static <T> Future<T> submit(ExecutorService service,
                                   Callable<T> callable)

Helper method to submit the callabale task, gets the original future object, and wrap it in another future object with the ability to decorate the Future.cancel(boolean) method; this decorator will block when future cancellation is invoked (and the "mayInterruptIfRunning" parameter is set to true).

Parameters:

service - the executor service

callable - a callable task

Returns:

decorated future object upon successful submission

See Also:

ExecutorService#submit(Callable)