Uses of Package
org.apache.cassandra.utils.concurrent
Packages that use org.apache.cassandra.utils.concurrent
Package
Description
File transfer
Hints subsystem consists of several components.
Non-blocking streaming with netty
-
Classes in org.apache.cassandra.utils.concurrent used by org.apache.cassandra.audit
-
Classes in org.apache.cassandra.utils.concurrent used by org.apache.cassandra.batchlog
-
Classes in org.apache.cassandra.utils.concurrent used by org.apache.cassandra.cache
-
Classes in org.apache.cassandra.utils.concurrent used by org.apache.cassandra.concurrentClassDescriptionOur default
Futureimplementation, with all state being managed without locks (except those used by the JVM).Our defaultFutureimplementation, with all state being managed without locks (except those used by the JVM).A generic signal consumer, supporting all of the typical patterns used in Cassandra.A Future that integrates several different (but equivalent) APIs used within Cassandra into a single concept, integrating also with ourAwaitableabstraction, to overall improve coherency and clarity in the codebase.Netty's DefaultPromise uses a mutex to coordinate notifiers AND waiters between the eventLoop and the other threads. -
Classes in org.apache.cassandra.utils.concurrent used by org.apache.cassandra.cql3
-
Classes in org.apache.cassandra.utils.concurrent used by org.apache.cassandra.dbClassDescriptionA Future that integrates several different (but equivalent) APIs used within Cassandra into a single concept, integrating also with our
Awaitableabstraction, to overall improve coherency and clarity in the codebase.A class for providing synchronization between producers and consumers that do not communicate directly with each other, but where the consumers need to process their work in contiguous batches.This class represents a synchronisation point providing ordering guarantees on operations started against the enclosing OpOrder.Represents a group of identically ordered operations, i.e.A collection of managed Ref references to RefCounted objects, and the objects they are referencing. -
Classes in org.apache.cassandra.utils.concurrent used by org.apache.cassandra.db.commitlogClassDescriptionA Future that integrates several different (but equivalent) APIs used within Cassandra into a single concept, integrating also with our
Awaitableabstraction, to overall improve coherency and clarity in the codebase.A relatively easy to use utility for general purpose thread signalling. -
Classes in org.apache.cassandra.utils.concurrent used by org.apache.cassandra.db.compactionClassDescriptionA Future that integrates several different (but equivalent) APIs used within Cassandra into a single concept, integrating also with our
Awaitableabstraction, to overall improve coherency and clarity in the codebase.A collection of managed Ref references to RefCounted objects, and the objects they are referencing. -
Classes in org.apache.cassandra.utils.concurrent used by org.apache.cassandra.db.compaction.unifiedClassDescriptionAn abstraction for Transactional behaviour.A simple abstract implementation of Transactional behaviour.
-
Classes in org.apache.cassandra.utils.concurrent used by org.apache.cassandra.db.compaction.writersClassDescriptionAn abstraction for Transactional behaviour.A simple abstract implementation of Transactional behaviour.
-
Classes in org.apache.cassandra.utils.concurrent used by org.apache.cassandra.db.lifecycleClassDescriptionRepresents a group of identically ordered operations, i.e.An abstraction for Transactional behaviour.A simple abstract implementation of Transactional behaviour.
-
Classes in org.apache.cassandra.utils.concurrent used by org.apache.cassandra.db.memtableClassDescriptionA Future that integrates several different (but equivalent) APIs used within Cassandra into a single concept, integrating also with our
Awaitableabstraction, to overall improve coherency and clarity in the codebase.This class represents a synchronisation point providing ordering guarantees on operations started against the enclosing OpOrder.Represents a group of identically ordered operations, i.e. -
Classes in org.apache.cassandra.utils.concurrent used by org.apache.cassandra.db.partitions
-
Classes in org.apache.cassandra.utils.concurrent used by org.apache.cassandra.db.repairClassDescriptionA Future that integrates several different (but equivalent) APIs used within Cassandra into a single concept, integrating also with our
Awaitableabstraction, to overall improve coherency and clarity in the codebase.A collection of managed Ref references to RefCounted objects, and the objects they are referencing. -
Classes in org.apache.cassandra.utils.concurrent used by org.apache.cassandra.db.rows
-
Classes in org.apache.cassandra.utils.concurrent used by org.apache.cassandra.db.streamingClassDescriptionAn object that needs ref counting does the two following: - defines a Tidy object that will cleanup once it's gone, (this must retain no references to the object we're tracking (only its resources and how to clean up)) Then, one of two options: 1) Construct a Ref directly pointing to it, and always use this Ref; or 2) - implements RefCounted - encapsulates a Ref, we'll call selfRef, to which it proxies all calls to RefCounted behaviours - users must ensure no references to the selfRef leak, or are retained outside of a method scope.
-
Classes in org.apache.cassandra.utils.concurrent used by org.apache.cassandra.dht
-
Classes in org.apache.cassandra.utils.concurrent used by org.apache.cassandra.fql
-
Classes in org.apache.cassandra.utils.concurrent used by org.apache.cassandra.hints
-
Classes in org.apache.cassandra.utils.concurrent used by org.apache.cassandra.index
-
Classes in org.apache.cassandra.utils.concurrent used by org.apache.cassandra.index.saiClassDescriptionA simple extension of AutoCloseable, that represents a resource that can be utilised in multiple locations, each managing their own closure of the resource, so that when the last such instance is closed all are.A simple abstract implementation of SharedCloseable
-
Classes in org.apache.cassandra.utils.concurrent used by org.apache.cassandra.index.sasi.disk
-
Classes in org.apache.cassandra.utils.concurrent used by org.apache.cassandra.io.compressClassDescriptionA simple extension of AutoCloseable, that represents a resource that can be utilised in multiple locations, each managing their own closure of the resource, so that when the last such instance is closed all are.A simple abstract implementation of SharedCloseableAn abstraction for Transactional behaviour.A simple abstract implementation of Transactional behaviour.An implementation of SharedCloseable that wraps a normal AutoCloseable, ensuring its close method is only called when all instances of SharedCloseable have been
-
Classes in org.apache.cassandra.utils.concurrent used by org.apache.cassandra.io.sstableClassDescriptionThis class represents a synchronisation point providing ordering guarantees on operations started against the enclosing OpOrder.An abstraction for Transactional behaviour.A simple abstract implementation of Transactional behaviour.
-
Classes in org.apache.cassandra.utils.concurrent used by org.apache.cassandra.io.sstable.formatClassDescriptionAn object that needs ref counting does the two following: - defines a Tidy object that will cleanup once it's gone, (this must retain no references to the object we're tracking (only its resources and how to clean up)) Then, one of two options: 1) Construct a Ref directly pointing to it, and always use this Ref; or 2) - implements RefCounted - encapsulates a Ref, we'll call selfRef, to which it proxies all calls to RefCounted behaviours - users must ensure no references to the selfRef leak, or are retained outside of a method scope.An object that needs ref counting does the two following: - defines a Tidy object that will cleanup once it's gone, (this must retain no references to the object we're tracking (only its resources and how to clean up)) Then, one of two options: 1) Construct a Ref directly pointing to it, and always use this Ref; or 2) - implements RefCounted - encapsulates a Ref, we'll call selfRef, to which it proxies all calls to RefCounted behaviours - users must ensure no references to the selfRef leak, or are retained outside of a method scope.An abstraction for Transactional behaviour.A simple abstract implementation of Transactional behaviour.
-
Classes in org.apache.cassandra.utils.concurrent used by org.apache.cassandra.io.sstable.format.bigClassDescriptionAn object that needs ref counting does the two following: - defines a Tidy object that will cleanup once it's gone, (this must retain no references to the object we're tracking (only its resources and how to clean up)) Then, one of two options: 1) Construct a Ref directly pointing to it, and always use this Ref; or 2) - implements RefCounted - encapsulates a Ref, we'll call selfRef, to which it proxies all calls to RefCounted behaviours - users must ensure no references to the selfRef leak, or are retained outside of a method scope.An abstraction for Transactional behaviour.A simple abstract implementation of Transactional behaviour.
-
Classes in org.apache.cassandra.utils.concurrent used by org.apache.cassandra.io.sstable.format.btiClassDescriptionAn object that needs ref counting does the two following: - defines a Tidy object that will cleanup once it's gone, (this must retain no references to the object we're tracking (only its resources and how to clean up)) Then, one of two options: 1) Construct a Ref directly pointing to it, and always use this Ref; or 2) - implements RefCounted - encapsulates a Ref, we'll call selfRef, to which it proxies all calls to RefCounted behaviours - users must ensure no references to the selfRef leak, or are retained outside of a method scope.A simple extension of AutoCloseable, that represents a resource that can be utilised in multiple locations, each managing their own closure of the resource, so that when the last such instance is closed all are.An abstraction for Transactional behaviour.A simple abstract implementation of Transactional behaviour.
-
Classes in org.apache.cassandra.utils.concurrent used by org.apache.cassandra.io.sstable.indexsummaryClassDescriptionA simple extension of AutoCloseable, that represents a resource that can be utilised in multiple locations, each managing their own closure of the resource, so that when the last such instance is closed all are.A simple abstract implementation of SharedCloseableAn implementation of SharedCloseable that wraps a normal AutoCloseable, ensuring its close method is only called when all instances of SharedCloseable have been
-
Classes in org.apache.cassandra.utils.concurrent used by org.apache.cassandra.io.utilClassDescriptionA simple extension of AutoCloseable, that represents a resource that can be utilised in multiple locations, each managing their own closure of the resource, so that when the last such instance is closed all are.A simple abstract implementation of SharedCloseableAn abstraction for Transactional behaviour.A simple abstract implementation of Transactional behaviour.
-
Classes in org.apache.cassandra.utils.concurrent used by org.apache.cassandra.netClassDescriptionOur default
Futureimplementation, with all state being managed without locks (except those used by the JVM).Our defaultFutureimplementation, with all state being managed without locks (except those used by the JVM).ExtendsAsyncFutureto implement thePromiseinterface.A generic signal consumer, supporting all of the typical patterns used in Cassandra.A Future that integrates several different (but equivalent) APIs used within Cassandra into a single concept, integrating also with ourAwaitableabstraction, to overall improve coherency and clarity in the codebase.A Promise that integratesPromisewith ourFutureAPI to improve clarity and coherence in the codebase. -
Classes in org.apache.cassandra.utils.concurrent used by org.apache.cassandra.repairClassDescriptionOur default
Futureimplementation, with all state being managed without locks (except those used by the JVM).Our defaultFutureimplementation, with all state being managed without locks (except those used by the JVM).A generic signal consumer, supporting all of the typical patterns used in Cassandra.A Future that integrates several different (but equivalent) APIs used within Cassandra into a single concept, integrating also with ourAwaitableabstraction, to overall improve coherency and clarity in the codebase. -
Classes in org.apache.cassandra.utils.concurrent used by org.apache.cassandra.repair.autorepair
-
Classes in org.apache.cassandra.utils.concurrent used by org.apache.cassandra.repair.consistent
-
Classes in org.apache.cassandra.utils.concurrent used by org.apache.cassandra.repair.messages
-
Classes in org.apache.cassandra.utils.concurrent used by org.apache.cassandra.schemaClassDescriptionA generic signal consumer, supporting all of the typical patterns used in Cassandra.
-
Classes in org.apache.cassandra.utils.concurrent used by org.apache.cassandra.serviceClassDescriptionSimpler API than java.util.concurrent.Condition; would be nice to extend it, but also nice to share API with Future, for which Netty's API is incompatible with java.util.concurrent.Condition
Awaitablefor explicit external signals.A Future that integrates several different (but equivalent) APIs used within Cassandra into a single concept, integrating also with ourAwaitableabstraction, to overall improve coherency and clarity in the codebase.An efficient stack/list that is expected to be ordinarily either empty or close to, and for which we need concurrent insertions and do not need to support removal - i.e. -
Classes in org.apache.cassandra.utils.concurrent used by org.apache.cassandra.service.paxos.cleanupClassDescriptionOur default
Futureimplementation, with all state being managed without locks (except those used by the JVM).Our defaultFutureimplementation, with all state being managed without locks (except those used by the JVM).A generic signal consumer, supporting all of the typical patterns used in Cassandra.A Future that integrates several different (but equivalent) APIs used within Cassandra into a single concept, integrating also with ourAwaitableabstraction, to overall improve coherency and clarity in the codebase. -
Classes in org.apache.cassandra.utils.concurrent used by org.apache.cassandra.service.paxos.v1
-
Classes in org.apache.cassandra.utils.concurrent used by org.apache.cassandra.service.readsClassDescriptionA simple append-only collection supporting an unbounded number of concurrent readers/writers, but a bounded number of items.
-
Classes in org.apache.cassandra.utils.concurrent used by org.apache.cassandra.service.reads.repairClassDescriptionOur default
Futureimplementation, with all state being managed without locks (except those used by the JVM).Our defaultFutureimplementation, with all state being managed without locks (except those used by the JVM).A generic signal consumer, supporting all of the typical patterns used in Cassandra.A Future that integrates several different (but equivalent) APIs used within Cassandra into a single concept, integrating also with ourAwaitableabstraction, to overall improve coherency and clarity in the codebase. -
Classes in org.apache.cassandra.utils.concurrent used by org.apache.cassandra.streamingClassDescriptionOur default
Futureimplementation, with all state being managed without locks (except those used by the JVM).Our defaultFutureimplementation, with all state being managed without locks (except those used by the JVM).A generic signal consumer, supporting all of the typical patterns used in Cassandra.A Future that integrates several different (but equivalent) APIs used within Cassandra into a single concept, integrating also with ourAwaitableabstraction, to overall improve coherency and clarity in the codebase. -
Classes in org.apache.cassandra.utils.concurrent used by org.apache.cassandra.streaming.async
-
Classes in org.apache.cassandra.utils.concurrent used by org.apache.cassandra.transportClassDescriptionA rate limiter implementation that allows callers to reserve permits that may only be available in the future, delegating to them decisions about how to schedule/delay work and whether or not to block execution to do so.
-
Classes in org.apache.cassandra.utils.concurrent used by org.apache.cassandra.utilsClassDescriptionA Future that integrates several different (but equivalent) APIs used within Cassandra into a single concept, integrating also with our
Awaitableabstraction, to overall improve coherency and clarity in the codebase.A simple extension of AutoCloseable, that represents a resource that can be utilised in multiple locations, each managing their own closure of the resource, so that when the last such instance is closed all are.A simple abstract implementation of SharedCloseableAn implementation of SharedCloseable that wraps a normal AutoCloseable, ensuring its close method is only called when all instances of SharedCloseable have been -
Classes in org.apache.cassandra.utils.concurrent used by org.apache.cassandra.utils.concurrentClassDescriptionOur default
Futureimplementation, with all state being managed without locks (except those used by the JVM).Our defaultFutureimplementation, with all state being managed without locks (except those used by the JVM).ExtendsAsyncFutureto implement thePromiseinterface.A generic signal consumer, supporting all of the typical patterns used in Cassandra.A barebones asynchronousAwaitable.A barebonesAwaitablethat uses mutual exclusion.Simpler API than java.util.concurrent.Condition; would be nice to extend it, but also nice to share API with Future, for which Netty's API is incompatible with java.util.concurrent.ConditionAwaitablefor explicit external signals.An asynchronousCondition.A Future that integrates several different (but equivalent) APIs used within Cassandra into a single concept, integrating also with ourAwaitableabstraction, to overall improve coherency and clarity in the codebase.Netty's PromiseCombiner is not threadsafe, and we combine futures from multiple event executors.An efficient stack/list that is expected to be ordinarily either empty or close to, and for which we need concurrent insertions and do not need to support removal - i.e.A simple thread local object reuse facility with limited capacity and no attempt at rebalancing pooling between threads.Thrown when unloading a value failed.A rate limiter implementation that allows callers to reserve permits that may only be available in the future, delegating to them decisions about how to schedule/delay work and whether or not to block execution to do so.This class represents a synchronisation point providing ordering guarantees on operations started against the enclosing OpOrder.Represents a group of identically ordered operations, i.e.A Promise that integratesPromisewith ourFutureAPI to improve clarity and coherence in the codebase.An object that needs ref counting does the two following: - defines a Tidy object that will cleanup once it's gone, (this must retain no references to the object we're tracking (only its resources and how to clean up)) Then, one of two options: 1) Construct a Ref directly pointing to it, and always use this Ref; or 2) - implements RefCounted - encapsulates a Ref, we'll call selfRef, to which it proxies all calls to RefCounted behaviours - users must ensure no references to the selfRef leak, or are retained outside of a method scope.An object that needs ref counting does the two following: - defines a Tidy object that will cleanup once it's gone, (this must retain no references to the object we're tracking (only its resources and how to clean up)) Then, one of two options: 1) Construct a Ref directly pointing to it, and always use this Ref; or 2) - implements RefCounted - encapsulates a Ref, we'll call selfRef, to which it proxies all calls to RefCounted behaviours - users must ensure no references to the selfRef leak, or are retained outside of a method scope.A collection of managed Ref references to RefCounted objects, and the objects they are referencing.A simple extension of AutoCloseable, that represents a resource that can be utilised in multiple locations, each managing their own closure of the resource, so that when the last such instance is closed all are.A simple abstract implementation of SharedCloseableNetty's DefaultPromise uses a mutex to coordinate notifiers AND waiters between the eventLoop and the other threads.ExtendsSyncFutureto implement thePromiseinterface.An abstraction for Transactional behaviour.UncheckedInterruptedException, to be thrown in places where an interrupt is unexpectedA relatively easy to use utility for general purpose thread signalling.A Signal is a one-time-use mechanism for a thread to wait for notification that some condition state has transitioned that it may be interested in (and hence should check if it is).An implementation of SharedCloseable that wraps a normal AutoCloseable, ensuring its close method is only called when all instances of SharedCloseable have been -
Classes in org.apache.cassandra.utils.concurrent used by org.apache.cassandra.utils.memoryClassDescriptionA Future that integrates several different (but equivalent) APIs used within Cassandra into a single concept, integrating also with our
Awaitableabstraction, to overall improve coherency and clarity in the codebase.Represents a group of identically ordered operations, i.e.A relatively easy to use utility for general purpose thread signalling. -
Classes in org.apache.cassandra.utils.concurrent used by org.apache.cassandra.utils.obs