Concurrency
in package
Specifies whether a command, that needs to be executed on multiple cluster nodes, should be executed sequentially, one node at a time, or in parallel on multiple nodes using the client's thread pool.
Table of Contents
Methods
- MaxThreads() : Concurrency
- Issue up to N commands in parallel threads. When a request completes, a new request will be issued until all threads are complete. This mode prevents too many parallel threads being created for large cluster implementations. The downside is extra threads will still need to be created (or taken from a thread pool).
- Parallel() : Concurrency
- Issue all commands in parallel threads. This mode has a performance advantage for extremely large batch sizes because each node can process the request immediately. The downside is extra threads will need to be created (or takedn from a thread pool).
- Sequential() : Concurrency
- Issue commands sequentially. This mode has a performance advantage for small to medium sized batch sizes because requests can be issued in the main transaction thread.
Methods
MaxThreads()
Issue up to N commands in parallel threads. When a request completes, a new request will be issued until all threads are complete. This mode prevents too many parallel threads being created for large cluster implementations. The downside is extra threads will still need to be created (or taken from a thread pool).
public
static MaxThreads(int $threads) : Concurrency
E.g. if there are 16 nodes/namespace combinations requested and concurrency is set to
MaxThreads(8)
, then batch requests will be made for 8 node/namespace combinations in
parallel threads. When a request completes, a new request will be issued until all 16
requests are complete.
Parameters
- $threads : int
Return values
ConcurrencyParallel()
Issue all commands in parallel threads. This mode has a performance advantage for extremely large batch sizes because each node can process the request immediately. The downside is extra threads will need to be created (or takedn from a thread pool).
public
static Parallel() : Concurrency
Return values
ConcurrencySequential()
Issue commands sequentially. This mode has a performance advantage for small to medium sized batch sizes because requests can be issued in the main transaction thread.
public
static Sequential() : Concurrency
This is the default.