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
All Methods Instance Methods Abstract Methods Concrete Methods 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
-
-
-
-
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 interfacejava.util.concurrent.ExecutorService
-
submit
public org.apache.cassandra.concurrent.AbstractLocalAwareExecutorService.FutureTask<?> submit(java.lang.Runnable task)
- Specified by:
submit
in interfacejava.util.concurrent.ExecutorService
-
submit
public <T> org.apache.cassandra.concurrent.AbstractLocalAwareExecutorService.FutureTask<T> submit(java.lang.Runnable task, T result)
- Specified by:
submit
in interfacejava.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 interfacejava.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 interfacejava.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 interfacejava.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 interfacejava.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 interfacejava.util.concurrent.Executor
-
execute
public void execute(java.lang.Runnable command, ExecutorLocals locals)
- Specified by:
execute
in interfaceLocalAwareExecutorService
-
-