Package org.apache.cassandra.concurrent

Class LocalAwareSingleThreadExecutorPlus

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.SingleThreadExecutorPlus

org.apache.cassandra.concurrent.LocalAwareSingleThreadExecutorPlus

All Implemented Interfaces:

Executor, ExecutorService, ExecutorPlus, LocalAwareExecutorPlus, LocalAwareSequentialExecutorPlus, ResizableThreadPool, SequentialExecutorPlus

public class LocalAwareSingleThreadExecutorPlus
extends SingleThreadExecutorPlus
implements LocalAwareSequentialExecutorPlus

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.cassandra.concurrent.SingleThreadExecutorPlus

SingleThreadExecutorPlus.AtLeastOnce

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

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

SequentialExecutorPlus.AtLeastOnceTrigger

Field Summary

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

blockingExecutionHandler

Method Summary

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

atLeastOnceTrigger, getCorePoolSize, getMaximumPoolSize, setCorePoolSize, setMaximumPoolSize

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, getKeepAliveTime, getLargestPoolSize, getPoolSize, getQueue, getRejectedExecutionHandler, getTaskCount, isShutdown, isTerminated, isTerminating, prestartAllCoreThreads, prestartCoreThread, purge, remove, setKeepAliveTime, 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

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

atLeastOnceTrigger