loader-rs 0.7.0

use cached::{Cached, UnboundCache};
use parking_lot::Mutex;
use std::{
    fmt::{Debug, Error, Formatter},
    hash::Hash,
    sync::Arc,
};

#[allow(clippy::module_name_repetitions)]
pub trait ThreadSafeCacheTrait<K: Clone + Eq + Hash, V> {
    fn set(&self, key: &K, value: Arc<V>);
    fn get(&self, key: &K) -> Option<Arc<V>>;
}

#[allow(clippy::module_name_repetitions)]
pub(in crate) struct ThreadSafeCacheImpl<K: Clone + Eq + Hash, V>(Mutex<UnboundCache<K, Arc<V>>>);

impl<K: Clone + Eq + Hash, V> Debug for ThreadSafeCacheImpl<K, V> {
    fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error> {
        let cache_lock = self.0.lock();
        write!(
            f,
            "ThreadSafeCache {{ cache_size: {}, cache_hits: {}, cache_misses: {} }}",
            cache_lock.cache_size(),
            cache_lock.cache_hits().unwrap_or(0),
            cache_lock.cache_misses().unwrap_or(0)
        )
    }
}

impl<K: Clone + Eq + Hash, V> Default for ThreadSafeCacheImpl<K, V> {
    fn default() -> Self {
        Self(Mutex::new(UnboundCache::new()))
    }
}

impl<K: Clone + Eq + Hash, V> ThreadSafeCacheTrait<K, V> for ThreadSafeCacheImpl<K, V> {
    fn set(&self, key: &K, value: Arc<V>) {
        self.0.lock().cache_set(key.clone(), value);
    }

    fn get(&self, key: &K) -> Option<Arc<V>> {
        self.0.lock().cache_get(key).cloned()
    }
}