Struct AsyncShardedHashMap 

pub struct AsyncShardedHashMap<K, V, S = FxBuildHasher>
where
    K: Eq + Hash + Clone + Send + Sync,
    V: Clone + Send + Sync,
    S: BuildHasher + Clone + Send + Sync,
{ /* private fields */ }

Available on crate feature async only.

Asynchronous sharded concurrent HashMap (Tokio RwLock).

Implementations

impl<K, V> AsyncShardedHashMap<K, V, FxBuildHasher>

where K: Eq + Hash + Clone + Send + Sync, V: Clone + Send + Sync,

pub fn new(shard_count: usize) -> Self

Create with default hasher.

impl<K, V, S> AsyncShardedHashMap<K, V, S>

where K: Eq + Hash + Clone + Send + Sync, V: Clone + Send + Sync, S: BuildHasher + Clone + Send + Sync,

pub fn with_shards_and_hasher(shard_count: usize, hasher: S) -> Self

Create with custom hasher.

pub fn shard_count(&self) -> usize

Configured shard capacity.

pub async fn initialized_shards(&self) -> usize

Number of initialized shards.

pub async fn insert(&self, key: K, value: V) -> Option<V>

Insert key/value asynchronously.

pub async fn get(&self, key: &K) -> Option<V>

Get cloned value; uses try_read first (fast path, reduces scheduler churn).

pub async fn remove(&self, key: &K) -> Option<V>

Remove key.

pub async fn len(&self) -> usize

Length (atomic).

pub async fn is_empty(&self) -> bool

Empty check.

pub async fn clear(&self)

Clear (retains allocated shards).

pub async fn iter(&self) -> Vec<(K, V)>

Snapshot iteration (async).

Steps:

1. Snapshot Arc list of initialized shards under read lock of the shard vector.
2. For each shard: try try_read; fallback to await read.
3. Clone inner HashMaps (short critical sections).
4. If rayon enabled, parallel flatten of snapshots.

Returns a materialized Vec.

Trait Implementations

impl<K, V, S> Clone for AsyncShardedHashMap<K, V, S>

where K: Eq + Hash + Clone + Send + Sync + Clone, V: Clone + Send + Sync + Clone, S: BuildHasher + Clone + Send + Sync + Clone,

fn clone(&self) -> AsyncShardedHashMap<K, V, S>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.