io.druid.query

Class PrioritizedExecutorService

java.lang.Object

java.util.concurrent.AbstractExecutorService

io.druid.query.PrioritizedExecutorService

All Implemented Interfaces:

com.google.common.util.concurrent.ListeningExecutorService, Executor, ExecutorService

public class PrioritizedExecutorService
extends AbstractExecutorService
implements com.google.common.util.concurrent.ListeningExecutorService

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	PrioritizedExecutorService.PrioritizedListenableFutureTask<V>

Constructor Summary

Constructors

Constructor and Description
PrioritizedExecutorService(ThreadPoolExecutor threadPoolExecutor)
PrioritizedExecutorService(ThreadPoolExecutor threadPoolExecutor, boolean allowRegularTasks, int defaultPriority)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	awaitTermination(long l, TimeUnit timeUnit)
static PrioritizedExecutorService	create(com.metamx.common.lifecycle.Lifecycle lifecycle, com.metamx.common.concurrent.ExecutorServiceConfig config)
void	execute(Runnable runnable)
int	getQueueSize()
boolean	isShutdown()
boolean	isTerminated()
protected <T> PrioritizedExecutorService.PrioritizedListenableFutureTask<T>	newTaskFor(Callable<T> callable)
protected <T> PrioritizedExecutorService.PrioritizedListenableFutureTask<T>	newTaskFor(Runnable runnable, T value)
void	shutdown()
List<Runnable>	shutdownNow()
<T> com.google.common.util.concurrent.ListenableFuture<T>	submit(Callable<T> task)
com.google.common.util.concurrent.ListenableFuture<?>	submit(Runnable task)
<T> com.google.common.util.concurrent.ListenableFuture<T>	submit(Runnable task, T result)

Methods inherited from class java.util.concurrent.AbstractExecutorService

invokeAll, invokeAll, invokeAny, invokeAny

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.google.common.util.concurrent.ListeningExecutorService

invokeAll, invokeAll

Methods inherited from interface java.util.concurrent.ExecutorService

invokeAny, invokeAny

Constructor Detail

PrioritizedExecutorService

public PrioritizedExecutorService(ThreadPoolExecutor threadPoolExecutor)

PrioritizedExecutorService

public PrioritizedExecutorService(ThreadPoolExecutor threadPoolExecutor,
                          boolean allowRegularTasks,
                          int defaultPriority)

Method Detail

create

public static PrioritizedExecutorService create(com.metamx.common.lifecycle.Lifecycle lifecycle,
                                com.metamx.common.concurrent.ExecutorServiceConfig config)

newTaskFor

protected <T> PrioritizedExecutorService.PrioritizedListenableFutureTask<T> newTaskFor(Runnable runnable,
                                                                           T value)

Overrides:

newTaskFor in class AbstractExecutorService

newTaskFor

protected <T> PrioritizedExecutorService.PrioritizedListenableFutureTask<T> newTaskFor(Callable<T> callable)

Overrides:

newTaskFor in class AbstractExecutorService

submit

public com.google.common.util.concurrent.ListenableFuture<?> submit(Runnable task)

Specified by:

submit in interface com.google.common.util.concurrent.ListeningExecutorService

Specified by:

submit in interface ExecutorService

Overrides:

submit in class AbstractExecutorService

submit

public <T> com.google.common.util.concurrent.ListenableFuture<T> submit(Runnable task,
                                                               @Nullable
                                                               T result)

Specified by:

submit in interface com.google.common.util.concurrent.ListeningExecutorService

Specified by:

submit in interface ExecutorService

Overrides:

submit in class AbstractExecutorService

submit

public <T> com.google.common.util.concurrent.ListenableFuture<T> submit(Callable<T> task)

Specified by:

submit in interface com.google.common.util.concurrent.ListeningExecutorService

Specified by:

submit in interface ExecutorService

Overrides:

submit in class AbstractExecutorService

shutdown

public void shutdown()

Specified by:

shutdown in interface ExecutorService

shutdownNow

public List<Runnable> shutdownNow()

Specified by:

shutdownNow in interface ExecutorService

isShutdown

public boolean isShutdown()

Specified by:

isShutdown in interface ExecutorService

isTerminated

public boolean isTerminated()

Specified by:

isTerminated in interface ExecutorService

awaitTermination

public boolean awaitTermination(long l,
                       TimeUnit timeUnit)
                         throws InterruptedException

Specified by:

awaitTermination in interface ExecutorService

Throws:

InterruptedException

execute

public void execute(Runnable runnable)

Specified by:

execute in interface Executor

getQueueSize

public int getQueueSize()