Uses of Package
org.apache.cassandra.concurrent
-
Classes in org.apache.cassandra.concurrent used by org.apache.cassandra.auth Class Description Shutdownable -
Classes in org.apache.cassandra.concurrent used by org.apache.cassandra.auth.jmx Class Description Shutdownable -
Classes in org.apache.cassandra.concurrent used by org.apache.cassandra.concurrent Class Description DebuggableTask Interface to include on a Runnable or Callable submitted to theSharedExecutorPoolto provide more detailed diagnostics.DebuggableTask.RunningDebuggableTask Wraps aDebuggableTaskto include the name of the thread running it.ExecutorBuilder Configure an executor before creating it.ExecutorBuilderFactory Entry point for configuring and creating new executors.ExecutorBuilderFactory.Jmxable Entry point for configuring and creating new executors.ExecutorFactory Entry point for configuring and creating new executors.ExecutorFactory.LocalAwareSubFactory ExecutorFactory.LocalAwareSubFactoryWithJMX ExecutorFactory.SimulatorSemantics ExecutorLocals ExecutorPlus Cassandra's extension ofExecutorService, using our ownFuture, supportingExecutorPlus.inExecutor(), and execution with associated resourcesExecutorPlus.execute(WithResources, Runnable)(which is primarily used for encapsulatingExecutorLocalswithout leaking implementing classes).ExecutorPlus.MaximumPoolSizeListener FutureTask A FutureTask that utilises Cassandra'sAsyncFuture, making it compatible withExecutorPlus.ImmediateExecutor InfiniteLoopExecutor.Daemon InfiniteLoopExecutor.InternalState InfiniteLoopExecutor.Interrupts InfiniteLoopExecutor.SimulatorSafe Interruptible Interruptible.SimpleTask A Task that only runs on NORMAL statesInterruptible.State Interruptible.Task LocalAwareExecutorPlus AnExecutorPlusthat is aware of, and propagates to execution, any ExecutorLocalsLocalAwareSequentialExecutorPlus ASequentialExecutorPlusthat is aware of, and propagates to execution, any ExecutorLocalsNamedThreadFactory This class is an implementation of the ThreadFactory interface.NamedThreadFactory.MetaFactory ResizableThreadPool ResizableThreadPoolMXBean ScheduledExecutorPlus SEPExecutor SEPExecutor.TakeTaskPermitResult SEPExecutorMBean SequentialExecutorPlus AnExecutorPlusthat guarantees the order of execution matches the order of task submission, and provides a simple mechanism for the recurring pattern of ensuring a job is executed at least once after some point in time (i.e.SequentialExecutorPlus.AtLeastOnceTrigger SharedExecutorPool A pool of worker threads that are shared between all Executors created with it.Shutdownable SingleThreadExecutorPlus SingleThreadExecutorPlus.AtLeastOnce Stage TaskFactory A simple mechanism to impose our desired semantics on the execution of a task without requiring a specialised executor service.TaskFactory.Standard ThreadPoolExecutorBase This class incorporates some Executor best practices for Cassandra.ThreadPoolExecutorBuilder Configure aThreadPoolExecutorPlus, applying Cassandra's best practices by default Core threads may timeout, and use a defaultThreadPoolExecutorBuilder.keepAlivetime inThreadPoolExecutorBuilder.keepAliveUnitsThreads share the sameThreadGroup, which may be configurably a child of a specifiedThreadGroupdescended from the same parent of theNamedThreadFactory.MetaFactoryBy default queues are unbounded in length The defaultRejectedExecutionHandleris implementation dependent, but may be overridden The defaultThread.UncaughtExceptionHandleris inherited fromNamedThreadFactory.MetaFactory, which in turn receives it from theExecutorBuilderFactoryThreadPoolExecutorPlus This class inherits Executor best practices fromThreadPoolExecutorBaseandThreadPoolExecutorBuilder. -
Classes in org.apache.cassandra.concurrent used by org.apache.cassandra.db.compaction Class Description ExecutorPlus Cassandra's extension ofExecutorService, using our ownFuture, supportingExecutorPlus.inExecutor(), and execution with associated resourcesExecutorPlus.execute(WithResources, Runnable)(which is primarily used for encapsulatingExecutorLocalswithout leaking implementing classes).ResizableThreadPool WrappedExecutorPlus -
Classes in org.apache.cassandra.concurrent used by org.apache.cassandra.metrics Class Description ExecutorPlus Cassandra's extension ofExecutorService, using our ownFuture, supportingExecutorPlus.inExecutor(), and execution with associated resourcesExecutorPlus.execute(WithResources, Runnable)(which is primarily used for encapsulatingExecutorLocalswithout leaking implementing classes).ResizableThreadPool -
Classes in org.apache.cassandra.concurrent used by org.apache.cassandra.net Class Description Stage -
Classes in org.apache.cassandra.concurrent used by org.apache.cassandra.repair Class Description ExecutorPlus Cassandra's extension ofExecutorService, using our ownFuture, supportingExecutorPlus.inExecutor(), and execution with associated resourcesExecutorPlus.execute(WithResources, Runnable)(which is primarily used for encapsulatingExecutorLocalswithout leaking implementing classes). -
Classes in org.apache.cassandra.concurrent used by org.apache.cassandra.service Class Description DebuggableTask Interface to include on a Runnable or Callable submitted to theSharedExecutorPoolto provide more detailed diagnostics.DebuggableTask.RunnableDebuggableTask ExecutorLocals.Impl ExecutorPlus Cassandra's extension ofExecutorService, using our ownFuture, supportingExecutorPlus.inExecutor(), and execution with associated resourcesExecutorPlus.execute(WithResources, Runnable)(which is primarily used for encapsulatingExecutorLocalswithout leaking implementing classes).Stage -
Classes in org.apache.cassandra.concurrent used by org.apache.cassandra.tracing Class Description ExecutorLocals.Impl -
Classes in org.apache.cassandra.concurrent used by org.apache.cassandra.transport Class Description DebuggableTask Interface to include on a Runnable or Callable submitted to theSharedExecutorPoolto provide more detailed diagnostics.DebuggableTask.RunnableDebuggableTask -
Classes in org.apache.cassandra.concurrent used by org.apache.cassandra.utils.memory Class Description Interruptible Shutdownable