Package org.apache.cassandra.concurrent

Class LocalAwareThreadPoolExecutorPlus

java.lang.Object

java.util.concurrent.AbstractExecutorService

java.util.concurrent.ThreadPoolExecutor

org.apache.cassandra.concurrent.ThreadPoolExecutorBase

org.apache.cassandra.concurrent.ThreadPoolExecutorPlus

org.apache.cassandra.concurrent.LocalAwareThreadPoolExecutorPlus

All Implemented Interfaces:

Executor, ExecutorService, ExecutorPlus, LocalAwareExecutorPlus, ResizableThreadPool

public class LocalAwareThreadPoolExecutorPlus
extends ThreadPoolExecutorPlus
implements LocalAwareExecutorPlus

Nested Class Summary

Nested classes/interfaces inherited from class java.util.concurrent.ThreadPoolExecutor

ThreadPoolExecutor.AbortPolicy, ThreadPoolExecutor.CallerRunsPolicy, ThreadPoolExecutor.DiscardOldestPolicy, ThreadPoolExecutor.DiscardPolicy

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

ExecutorPlus.MaximumPoolSizeListener

Field Summary

Fields inherited from class org.apache.cassandra.concurrent.ThreadPoolExecutorBase

blockingExecutionHandler

Method Summary

Methods inherited from class org.apache.cassandra.concurrent.ThreadPoolExecutorPlus

execute, execute, getMaxTasksQueued, inExecutor, newTaskFor, newTaskFor, submit, submit, submit, submit, submit, submit

Methods inherited from class org.apache.cassandra.concurrent.ThreadPoolExecutorBase

getActiveTaskCount, getCoreThreads, getMaximumThreads, getPendingTaskCount, getThreadFactory, onShutdown, onShutdown, setCoreThreads, setMaximumThreads, shutdown, shutdownNow, terminated, toString

Methods inherited from class java.util.concurrent.ThreadPoolExecutor

afterExecute, allowCoreThreadTimeOut, allowsCoreThreadTimeOut, awaitTermination, beforeExecute, finalize, getActiveCount, getCompletedTaskCount, getCorePoolSize, getKeepAliveTime, getLargestPoolSize, getMaximumPoolSize, getPoolSize, getQueue, getRejectedExecutionHandler, getTaskCount, isShutdown, isTerminated, isTerminating, prestartAllCoreThreads, prestartCoreThread, purge, remove, setCorePoolSize, setKeepAliveTime, setMaximumPoolSize, setRejectedExecutionHandler, setThreadFactory

Methods inherited from class java.util.concurrent.AbstractExecutorService

invokeAll, invokeAll, invokeAny, invokeAny

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.concurrent.Executor

execute

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

execute, inExecutor, invokeAll, invokeAll, invokeAny, invokeAny, maybeExecuteImmediately, submit, submit, submit, submit, submit, submit

Methods inherited from interface java.util.concurrent.ExecutorService

awaitTermination, isShutdown, isTerminated, shutdown, shutdownNow

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

getActiveTaskCount, getCompletedTaskCount, getCorePoolSize, getMaximumPoolSize, getMaxTasksQueued, getPendingTaskCount, oldestTaskQueueTime, setCorePoolSize, setMaximumPoolSize