Trait lockable::Lockable

pub trait Lockable<K, V> {
    type Guard<'a>
       where Self: 'a,
             K: 'a,
             V: 'a;
    type OwnedGuard;
    type SyncLimit<'a, OnEvictFn, E>
       where Self: 'a,
             K: 'a,
             V: 'a,
             OnEvictFn: FnMut(Vec<Self::Guard<'a>>) -> Result<(), E>;
    type SyncLimitOwned<OnEvictFn, E>
       where OnEvictFn: FnMut(Vec<Self::OwnedGuard>) -> Result<(), E>;
    type AsyncLimit<'a, OnEvictFn, E, F>
       where Self: 'a,
             K: 'a,
             V: 'a,
             F: Future<Output = Result<(), E>>,
             OnEvictFn: FnMut(Vec<Self::Guard<'a>>) -> F;
    type AsyncLimitOwned<OnEvictFn, E, F>
       where F: Future<Output = Result<(), E>>,
             OnEvictFn: FnMut(Vec<Self::OwnedGuard>) -> F;
}

A common trait for both LockableHashMap and LockableLruCache that offers some common functionalities.

Required Associated Types

type Guard<'a> where Self: 'a, K: 'a, V: 'a

A non-owning guard holding a lock for an entry in a LockableHashMap or a LockableLruCache. This guard is created via LockableHashMap::blocking_lock, LockableHashMap::async_lock or LockableHashMap::try_lock, or the corresponding LockableLruCache methods, and its lifetime is bound to the lifetime of the LockableHashMap/LockableLruCache.

See the documentation of Guard for methods.

Examples:

use lockable::{AsyncLimit, Lockable, LockableHashMap};

let map = LockableHashMap::<usize, String>::new();
let guard: <LockableHashMap<usize, String> as Lockable<usize, String>>::Guard<'_> =
    map.async_lock(1, AsyncLimit::no_limit()).await?;

type OwnedGuard

A owning guard holding a lock for an entry in a LockableHashMap or a LockableLruCache. This guard is created via LockableHashMap::blocking_lock_owned, LockableHashMap::async_lock_owned or LockableHashMap::try_lock_owned, or the corresponding LockableLruCache methods, and its lifetime is bound to the lifetime of the LockableHashMap/LockableLruCache within its Arc.

See the documentation of Guard for methods.

Examples:

use lockable::{AsyncLimit, Lockable, LockableHashMap};
use std::sync::Arc;

let map = Arc::new(LockableHashMap::<usize, String>::new());
let guard: <LockableHashMap<usize, String> as Lockable<usize, String>>::OwnedGuard =
    map.async_lock_owned(1, AsyncLimit::no_limit()).await?;

type SyncLimit<'a, OnEvictFn, E> where Self: 'a, K: 'a, V: 'a, OnEvictFn: FnMut(Vec<Self::Guard<'a>>) -> Result<(), E>

TODO Documentation

type SyncLimitOwned<OnEvictFn, E> where OnEvictFn: FnMut(Vec<Self::OwnedGuard>) -> Result<(), E>

TODO Documentation

type AsyncLimit<'a, OnEvictFn, E, F> where Self: 'a, K: 'a, V: 'a, F: Future<Output = Result<(), E>>, OnEvictFn: FnMut(Vec<Self::Guard<'a>>) -> F

TODO Documentation

type AsyncLimitOwned<OnEvictFn, E, F> where F: Future<Output = Result<(), E>>, OnEvictFn: FnMut(Vec<Self::OwnedGuard>) -> F

TODO Documentation

Object Safety

This trait is not object safe.

Implementors

impl<K> Lockable<K, ()> for LockPool<K>

where K: Eq + PartialEq + Hash + Clone,

type Guard<'a> = <LockableHashMap<K, ()> as Lockable<K, ()>>::Guard<'a> where K: 'a

type OwnedGuard = <LockableHashMap<K, ()> as Lockable<K, ()>>::OwnedGuard

type SyncLimit<'a, OnEvictFn, E> = <LockableHashMap<K, ()> as Lockable<K, ()>>::SyncLimit<'a, OnEvictFn, E> where OnEvictFn: FnMut(Vec<Self::Guard<'a>>) -> Result<(), E>, K: 'a

type SyncLimitOwned<OnEvictFn, E> = <LockableHashMap<K, ()> as Lockable<K, ()>>::SyncLimitOwned<OnEvictFn, E> where OnEvictFn: FnMut(Vec<Self::OwnedGuard>) -> Result<(), E>

type AsyncLimit<'a, OnEvictFn, E, F> = <LockableHashMap<K, ()> as Lockable<K, ()>>::AsyncLimit<'a, OnEvictFn, E, F> where F: Future<Output = Result<(), E>>, OnEvictFn: FnMut(Vec<Self::Guard<'a>>) -> F, K: 'a

type AsyncLimitOwned<OnEvictFn, E, F> = <LockableHashMap<K, ()> as Lockable<K, ()>>::AsyncLimitOwned<OnEvictFn, E, F> where F: Future<Output = Result<(), E>>, OnEvictFn: FnMut(Vec<Self::OwnedGuard>) -> F

impl<K, V> Lockable<K, V> for LockableHashMap<K, V>

where K: Eq + PartialEq + Hash + Clone,

type Guard<'a> = Guard<HashMap<K, Arc<Mutex<EntryValue<V>>>>, V, NoopHooks, &'a LockableMapImpl<HashMap<K, Arc<Mutex<EntryValue<V>>>>, V, NoopHooks>> where K: 'a, V: 'a

type OwnedGuard = Guard<HashMap<K, Arc<Mutex<EntryValue<V>>>>, V, NoopHooks, Arc<LockableHashMap<K, V>>>

type SyncLimit<'a, OnEvictFn, E> = SyncLimit<HashMap<K, Arc<Mutex<EntryValue<V>>>>, V, NoopHooks, &'a LockableMapImpl<HashMap<K, Arc<Mutex<EntryValue<V>>>>, V, NoopHooks>, E, OnEvictFn> where OnEvictFn: FnMut(Vec<Self::Guard<'a>>) -> Result<(), E>, K: 'a, V: 'a

type SyncLimitOwned<OnEvictFn, E> = SyncLimit<HashMap<K, Arc<Mutex<EntryValue<V>>>>, V, NoopHooks, Arc<LockableHashMap<K, V>>, E, OnEvictFn> where OnEvictFn: FnMut(Vec<Self::OwnedGuard>) -> Result<(), E>

type AsyncLimit<'a, OnEvictFn, E, F> = AsyncLimit<HashMap<K, Arc<Mutex<EntryValue<V>>>>, V, NoopHooks, &'a LockableMapImpl<HashMap<K, Arc<Mutex<EntryValue<V>>>>, V, NoopHooks>, E, F, OnEvictFn> where F: Future<Output = Result<(), E>>, OnEvictFn: FnMut(Vec<Self::Guard<'a>>) -> F, K: 'a, V: 'a

type AsyncLimitOwned<OnEvictFn, E, F> = AsyncLimit<HashMap<K, Arc<Mutex<EntryValue<V>>>>, V, NoopHooks, Arc<LockableHashMap<K, V>>, E, F, OnEvictFn> where F: Future<Output = Result<(), E>>, OnEvictFn: FnMut(Vec<Self::OwnedGuard>) -> F

impl<K, V, Time> Lockable<K, V> for LockableLruCache<K, V, Time>

where K: Eq + PartialEq + Hash + Clone, Time: TimeProvider + Default + Clone,

type Guard<'a> = Guard<LruCache<K, Arc<Mutex<EntryValue<CacheEntry<V>>>>>, V, LruCacheHooks<Time>, &'a LockableMapImpl<LruCache<K, Arc<Mutex<EntryValue<CacheEntry<V>>>>>, V, LruCacheHooks<Time>>> where K: 'a, V: 'a, Time: 'a

type OwnedGuard = Guard<LruCache<K, Arc<Mutex<EntryValue<CacheEntry<V>>>>>, V, LruCacheHooks<Time>, Arc<LockableLruCache<K, V, Time>>>

type SyncLimit<'a, OnEvictFn, E> = SyncLimit<LruCache<K, Arc<Mutex<EntryValue<CacheEntry<V>>>>>, V, LruCacheHooks<Time>, &'a LockableMapImpl<LruCache<K, Arc<Mutex<EntryValue<CacheEntry<V>>>>>, V, LruCacheHooks<Time>>, E, OnEvictFn> where OnEvictFn: FnMut(Vec<Self::Guard<'a>>) -> Result<(), E>, K: 'a, V: 'a, Time: 'a

type SyncLimitOwned<OnEvictFn, E> = SyncLimit<LruCache<K, Arc<Mutex<EntryValue<CacheEntry<V>>>>>, V, LruCacheHooks<Time>, Arc<LockableLruCache<K, V, Time>>, E, OnEvictFn> where OnEvictFn: FnMut(Vec<Self::OwnedGuard>) -> Result<(), E>

type AsyncLimit<'a, OnEvictFn, E, F> = AsyncLimit<LruCache<K, Arc<Mutex<EntryValue<CacheEntry<V>>>>>, V, LruCacheHooks<Time>, &'a LockableMapImpl<LruCache<K, Arc<Mutex<EntryValue<CacheEntry<V>>>>>, V, LruCacheHooks<Time>>, E, F, OnEvictFn> where F: Future<Output = Result<(), E>>, OnEvictFn: FnMut(Vec<Self::Guard<'a>>) -> F, K: 'a, V: 'a, Time: 'a

type AsyncLimitOwned<OnEvictFn, E, F> = AsyncLimit<LruCache<K, Arc<Mutex<EntryValue<CacheEntry<V>>>>>, V, LruCacheHooks<Time>, Arc<LockableLruCache<K, V, Time>>, E, F, OnEvictFn> where F: Future<Output = Result<(), E>>, OnEvictFn: FnMut(Vec<Self::OwnedGuard>) -> F