From 4ba03be97e6cc7e790bbc9bfc18caaa228c8a262 Mon Sep 17 00:00:00 2001 From: Botahamec Date: Fri, 28 Feb 2025 16:09:11 -0500 Subject: Scoped lock API --- src/collection/guard.rs | 83 +++++++++++++++---------------------------------- 1 file changed, 25 insertions(+), 58 deletions(-) (limited to 'src/collection/guard.rs') diff --git a/src/collection/guard.rs b/src/collection/guard.rs index eea13ed..78d9895 100644 --- a/src/collection/guard.rs +++ b/src/collection/guard.rs @@ -2,41 +2,11 @@ use std::fmt::{Debug, Display}; use std::hash::Hash; use std::ops::{Deref, DerefMut}; -use crate::key::Keyable; - use super::LockGuard; -#[mutants::skip] // it's hard to get two guards safely -#[cfg(not(tarpaulin_include))] -impl PartialEq for LockGuard<'_, Guard, Key> { - fn eq(&self, other: &Self) -> bool { - self.guard.eq(&other.guard) - } -} - -#[mutants::skip] // it's hard to get two guards safely -#[cfg(not(tarpaulin_include))] -impl PartialOrd for LockGuard<'_, Guard, Key> { - fn partial_cmp(&self, other: &Self) -> Option { - self.guard.partial_cmp(&other.guard) - } -} - -#[mutants::skip] // it's hard to get two guards safely -#[cfg(not(tarpaulin_include))] -impl Eq for LockGuard<'_, Guard, Key> {} - -#[mutants::skip] // it's hard to get two guards safely -#[cfg(not(tarpaulin_include))] -impl Ord for LockGuard<'_, Guard, Key> { - fn cmp(&self, other: &Self) -> std::cmp::Ordering { - self.guard.cmp(&other.guard) - } -} - #[mutants::skip] // hashing involves RNG and is hard to test #[cfg(not(tarpaulin_include))] -impl Hash for LockGuard<'_, Guard, Key> { +impl Hash for LockGuard { fn hash(&self, state: &mut H) { self.guard.hash(state) } @@ -44,19 +14,19 @@ impl Hash for LockGuard<'_, Guard, Key> { #[mutants::skip] #[cfg(not(tarpaulin_include))] -impl Debug for LockGuard<'_, Guard, Key> { +impl Debug for LockGuard { fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result { Debug::fmt(&**self, f) } } -impl Display for LockGuard<'_, Guard, Key> { +impl Display for LockGuard { fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result { Display::fmt(&**self, f) } } -impl Deref for LockGuard<'_, Guard, Key> { +impl Deref for LockGuard { type Target = Guard; fn deref(&self) -> &Self::Target { @@ -64,19 +34,19 @@ impl Deref for LockGuard<'_, Guard, Key> { } } -impl DerefMut for LockGuard<'_, Guard, Key> { +impl DerefMut for LockGuard { fn deref_mut(&mut self) -> &mut Self::Target { &mut self.guard } } -impl AsRef for LockGuard<'_, Guard, Key> { +impl AsRef for LockGuard { fn as_ref(&self) -> &Guard { &self.guard } } -impl AsMut for LockGuard<'_, Guard, Key> { +impl AsMut for LockGuard { fn as_mut(&mut self) -> &mut Guard { &mut self.guard } @@ -97,56 +67,53 @@ mod tests { #[test] fn deref_mut_works() { - let mut key = ThreadKey::get().unwrap(); + let key = ThreadKey::get().unwrap(); let locks = (Mutex::new(1), Mutex::new(2)); let lock = LockCollection::new_ref(&locks); - let mut guard = lock.lock(&mut key); + let mut guard = lock.lock(key); *guard.0 = 3; - drop(guard); + let key = LockCollection::<(Mutex<_>, Mutex<_>)>::unlock(guard); - let guard = locks.0.lock(&mut key); + let guard = locks.0.lock(key); assert_eq!(*guard, 3); - drop(guard); + let key = Mutex::unlock(guard); - let guard = locks.1.lock(&mut key); + let guard = locks.1.lock(key); assert_eq!(*guard, 2); - drop(guard); } #[test] fn as_ref_works() { - let mut key = ThreadKey::get().unwrap(); + let key = ThreadKey::get().unwrap(); let locks = (Mutex::new(1), Mutex::new(2)); let lock = LockCollection::new_ref(&locks); - let mut guard = lock.lock(&mut key); + let mut guard = lock.lock(key); *guard.0 = 3; - drop(guard); + let key = LockCollection::<(Mutex<_>, Mutex<_>)>::unlock(guard); - let guard = locks.0.lock(&mut key); + let guard = locks.0.lock(key); assert_eq!(guard.as_ref(), &3); - drop(guard); + let key = Mutex::unlock(guard); - let guard = locks.1.lock(&mut key); + let guard = locks.1.lock(key); assert_eq!(guard.as_ref(), &2); - drop(guard); } #[test] fn as_mut_works() { - let mut key = ThreadKey::get().unwrap(); + let key = ThreadKey::get().unwrap(); let locks = (Mutex::new(1), Mutex::new(2)); let lock = LockCollection::new_ref(&locks); - let mut guard = lock.lock(&mut key); + let mut guard = lock.lock(key); let guard_mut = guard.as_mut(); *guard_mut.0 = 3; - drop(guard); + let key = LockCollection::<(Mutex<_>, Mutex<_>)>::unlock(guard); - let guard = locks.0.lock(&mut key); + let guard = locks.0.lock(key); assert_eq!(guard.as_ref(), &3); - drop(guard); + let key = Mutex::unlock(guard); - let guard = locks.1.lock(&mut key); + let guard = locks.1.lock(key); assert_eq!(guard.as_ref(), &2); - drop(guard); } } -- cgit v1.2.3