summaryrefslogtreecommitdiff
path: root/src/rwlock/read_lock.rs
diff options
context:
space:
mode:
authorMica White <botahamec@outlook.com>2024-03-10 20:21:00 -0400
committerMica White <botahamec@outlook.com>2024-03-10 20:21:00 -0400
commitfe67aa262f1b04fb6c38683d9221c3a2fafcc35a (patch)
tree91366e032219f5e29ff4ba993598ae581aefa829 /src/rwlock/read_lock.rs
parente8d25c9e6e7d5c3a5a14219fc77ea98760cef790 (diff)
Reorganization
Diffstat (limited to 'src/rwlock/read_lock.rs')
-rw-r--r--src/rwlock/read_lock.rs60
1 files changed, 60 insertions, 0 deletions
diff --git a/src/rwlock/read_lock.rs b/src/rwlock/read_lock.rs
new file mode 100644
index 0000000..dbab8de
--- /dev/null
+++ b/src/rwlock/read_lock.rs
@@ -0,0 +1,60 @@
+use std::fmt::Debug;
+
+use lock_api::RawRwLock;
+
+use crate::key::Keyable;
+
+use super::{ReadLock, RwLock, RwLockReadGuard, RwLockReadRef};
+
+impl<'a, T: ?Sized, R> Debug for ReadLock<'a, T, R> {
+ fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
+ f.write_str(&format!("ReadLock<{}>", std::any::type_name::<T>()))
+ }
+}
+
+impl<'a, T: ?Sized, R> From<&'a RwLock<T, R>> for ReadLock<'a, T, R> {
+ fn from(value: &'a RwLock<T, R>) -> Self {
+ Self::new(value)
+ }
+}
+
+impl<'a, T: ?Sized, R> AsRef<RwLock<T, R>> for ReadLock<'a, T, R> {
+ fn as_ref(&self) -> &RwLock<T, R> {
+ self.0
+ }
+}
+
+impl<'a, T: ?Sized, R> ReadLock<'a, T, R> {
+ #[must_use]
+ pub const fn new(rwlock: &'a RwLock<T, R>) -> Self {
+ Self(rwlock)
+ }
+}
+
+impl<'a, T: ?Sized, R: RawRwLock> ReadLock<'a, T, R> {
+ pub fn lock<'s, 'key: 's, Key: Keyable + 'key>(
+ &'s self,
+ key: Key,
+ ) -> RwLockReadGuard<'_, 'key, T, Key, R> {
+ self.0.read(key)
+ }
+
+ pub(crate) unsafe fn lock_no_key(&self) -> RwLockReadRef<'_, T, R> {
+ self.0.read_no_key()
+ }
+
+ pub fn try_lock<'s, 'key: 's, Key: Keyable + 'key>(
+ &'s self,
+ key: Key,
+ ) -> Option<RwLockReadGuard<'_, 'key, T, Key, R>> {
+ self.0.try_read(key)
+ }
+
+ pub(crate) unsafe fn try_lock_no_key(&self) -> Option<RwLockReadRef<'_, T, R>> {
+ self.0.try_read_no_key()
+ }
+
+ pub fn unlock<'key, Key: Keyable + 'key>(guard: RwLockReadGuard<'_, 'key, T, Key, R>) -> Key {
+ RwLock::unlock_read(guard)
+ }
+}