Package org.apache.cassandra.concurrent

Class AbstractLocalAwareExecutorService

java.lang.Object

org.apache.cassandra.concurrent.AbstractLocalAwareExecutorService

All Implemented Interfaces:

java.util.concurrent.Executor, java.util.concurrent.ExecutorService, LocalAwareExecutorService, ResizableThreadPool

Direct Known Subclasses:

SEPExecutor

public abstract class AbstractLocalAwareExecutorService
extends java.lang.Object
implements LocalAwareExecutorService

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.cassandra.concurrent.LocalAwareExecutorService

LocalAwareExecutorService.MaximumPoolSizeListener

Constructor Summary

Constructors

Constructor	Description
AbstractLocalAwareExecutorService()

Method Summary

Modifier and Type	Method	Description
protected abstract void	addTask(org.apache.cassandra.concurrent.AbstractLocalAwareExecutorService.FutureTask<?> futureTask)
void	execute(java.lang.Runnable command)
void	execute(java.lang.Runnable command, ExecutorLocals locals)
<T> java.util.List<java.util.concurrent.Future<T>>	invokeAll(java.util.Collection<? extends java.util.concurrent.Callable<T>> tasks)
<T> java.util.List<java.util.concurrent.Future<T>>	invokeAll(java.util.Collection<? extends java.util.concurrent.Callable<T>> tasks, long timeout, java.util.concurrent.TimeUnit unit)
<T> T	invokeAny(java.util.Collection<? extends java.util.concurrent.Callable<T>> tasks)
<T> T	invokeAny(java.util.Collection<? extends java.util.concurrent.Callable<T>> tasks, long timeout, java.util.concurrent.TimeUnit unit)
protected <T> org.apache.cassandra.concurrent.AbstractLocalAwareExecutorService.FutureTask<T>	newTaskFor(java.lang.Runnable runnable, T result)
protected <T> org.apache.cassandra.concurrent.AbstractLocalAwareExecutorService.FutureTask<T>	newTaskFor(java.lang.Runnable runnable, T result, ExecutorLocals locals)
protected <T> org.apache.cassandra.concurrent.AbstractLocalAwareExecutorService.FutureTask<T>	newTaskFor(java.util.concurrent.Callable<T> callable)
protected <T> org.apache.cassandra.concurrent.AbstractLocalAwareExecutorService.FutureTask<T>	newTaskFor(java.util.concurrent.Callable<T> callable, ExecutorLocals locals)
protected abstract void	onCompletion()
org.apache.cassandra.concurrent.AbstractLocalAwareExecutorService.FutureTask<?>	submit(java.lang.Runnable task)
<T> org.apache.cassandra.concurrent.AbstractLocalAwareExecutorService.FutureTask<T>	submit(java.lang.Runnable task, T result)
<T> org.apache.cassandra.concurrent.AbstractLocalAwareExecutorService.FutureTask<T>	submit(java.util.concurrent.Callable<T> task)	Task Submission / Creation / Objects

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.concurrent.ExecutorService

awaitTermination, isShutdown, isTerminated, shutdown, shutdownNow

Methods inherited from interface org.apache.cassandra.concurrent.LocalAwareExecutorService

getActiveTaskCount, getCompletedTaskCount, getMaxTasksQueued, getPendingTaskCount, maybeExecuteImmediately

Methods inherited from interface org.apache.cassandra.concurrent.ResizableThreadPool

getCorePoolSize, getMaximumPoolSize, setCorePoolSize, setMaximumPoolSize

Constructor Detail

AbstractLocalAwareExecutorService

public AbstractLocalAwareExecutorService()

Method Detail

addTask

protected abstract void addTask(org.apache.cassandra.concurrent.AbstractLocalAwareExecutorService.FutureTask<?> futureTask)

onCompletion

protected abstract void onCompletion()

submit

public <T> org.apache.cassandra.concurrent.AbstractLocalAwareExecutorService.FutureTask<T> submit(java.util.concurrent.Callable<T> task)

Task Submission / Creation / Objects

Specified by:

submit in interface java.util.concurrent.ExecutorService

submit

public org.apache.cassandra.concurrent.AbstractLocalAwareExecutorService.FutureTask<?> submit(java.lang.Runnable task)

Specified by:

submit in interface java.util.concurrent.ExecutorService

submit

public <T> org.apache.cassandra.concurrent.AbstractLocalAwareExecutorService.FutureTask<T> submit(java.lang.Runnable task,
                                                                                                  T result)

Specified by:

submit in interface java.util.concurrent.ExecutorService

invokeAll

public <T> java.util.List<java.util.concurrent.Future<T>> invokeAll(java.util.Collection<? extends java.util.concurrent.Callable<T>> tasks)

Specified by:

invokeAll in interface java.util.concurrent.ExecutorService

invokeAll

public <T> java.util.List<java.util.concurrent.Future<T>> invokeAll(java.util.Collection<? extends java.util.concurrent.Callable<T>> tasks,
                                                                    long timeout,
                                                                    java.util.concurrent.TimeUnit unit)
                                                             throws java.lang.InterruptedException

Specified by:

invokeAll in interface java.util.concurrent.ExecutorService

Throws:

java.lang.InterruptedException

invokeAny

public <T> T invokeAny(java.util.Collection<? extends java.util.concurrent.Callable<T>> tasks)
                throws java.lang.InterruptedException,
                       java.util.concurrent.ExecutionException

Specified by:

invokeAny in interface java.util.concurrent.ExecutorService

Throws:

java.lang.InterruptedException

java.util.concurrent.ExecutionException

invokeAny

public <T> T invokeAny(java.util.Collection<? extends java.util.concurrent.Callable<T>> tasks,
                       long timeout,
                       java.util.concurrent.TimeUnit unit)
                throws java.lang.InterruptedException,
                       java.util.concurrent.ExecutionException,
                       java.util.concurrent.TimeoutException

Specified by:

invokeAny in interface java.util.concurrent.ExecutorService

Throws:

java.lang.InterruptedException

java.util.concurrent.ExecutionException

java.util.concurrent.TimeoutException

newTaskFor

protected <T> org.apache.cassandra.concurrent.AbstractLocalAwareExecutorService.FutureTask<T> newTaskFor(java.lang.Runnable runnable,
                                                                                                         T result)

newTaskFor

protected <T> org.apache.cassandra.concurrent.AbstractLocalAwareExecutorService.FutureTask<T> newTaskFor(java.lang.Runnable runnable,
                                                                                                         T result,
                                                                                                         ExecutorLocals locals)

newTaskFor

protected <T> org.apache.cassandra.concurrent.AbstractLocalAwareExecutorService.FutureTask<T> newTaskFor(java.util.concurrent.Callable<T> callable)

newTaskFor

protected <T> org.apache.cassandra.concurrent.AbstractLocalAwareExecutorService.FutureTask<T> newTaskFor(java.util.concurrent.Callable<T> callable,
                                                                                                         ExecutorLocals locals)

execute

public void execute(java.lang.Runnable command)

Specified by:

execute in interface java.util.concurrent.Executor

execute

public void execute(java.lang.Runnable command,
                    ExecutorLocals locals)

Specified by:

execute in interface LocalAwareExecutorService