Uses of Package
org.apache.cassandra.concurrent
Packages that use org.apache.cassandra.concurrent
Package
Description
-
Classes in org.apache.cassandra.concurrent used by org.apache.cassandra.auth
-
Classes in org.apache.cassandra.concurrent used by org.apache.cassandra.auth.jmx
-
Classes in org.apache.cassandra.concurrent used by org.apache.cassandra.concurrentClassDescriptionInterface to include on a Runnable or Callable submitted to the
SharedExecutorPoolto provide more detailed diagnostics.Wraps aDebuggableTaskto include the name of the thread running it.Configure an executor before creating it.Entry point for configuring and creating new executors.Entry point for configuring and creating new executors.Entry point for configuring and creating new executors.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).A FutureTask that utilises Cassandra'sAsyncFuture, making it compatible withExecutorPlus.A Task that only runs on NORMAL statesAnExecutorPlusthat is aware of, and propagates to execution, any ExecutorLocalsASequentialExecutorPlusthat is aware of, and propagates to execution, any ExecutorLocalsThis class is an implementation of the ThreadFactory interface.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.A pool of worker threads that are shared between all Executors created with it.A simple mechanism to impose our desired semantics on the execution of a task without requiring a specialised executor service.This class incorporates some Executor best practices for Cassandra.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 theExecutorBuilderFactoryThis class inherits Executor best practices fromThreadPoolExecutorBaseandThreadPoolExecutorBuilder. -
Classes in org.apache.cassandra.concurrent used by org.apache.cassandra.db.compactionClassDescriptionCassandra's extension of
ExecutorService, 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.metricsClassDescriptionCassandra's extension of
ExecutorService, 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.net
-
Classes in org.apache.cassandra.concurrent used by org.apache.cassandra.repairClassDescriptionEntry point for configuring and creating new executors.Cassandra's extension of
ExecutorService, 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.repair.autorepair
-
Classes in org.apache.cassandra.concurrent used by org.apache.cassandra.serviceClassDescriptionInterface to include on a Runnable or Callable submitted to the
SharedExecutorPoolto provide more detailed diagnostics.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.tracing
-
Classes in org.apache.cassandra.concurrent used by org.apache.cassandra.transportClassDescriptionInterface to include on a Runnable or Callable submitted to the
SharedExecutorPoolto provide more detailed diagnostics. -
Classes in org.apache.cassandra.concurrent used by org.apache.cassandra.utils.memory