summaryrefslogtreecommitdiff
path: root/src/collection/boxed.rs
diff options
context:
space:
mode:
authorMica White <botahamec@gmail.com>2024-07-16 17:18:33 -0400
committerMica White <botahamec@gmail.com>2024-07-17 16:37:21 -0400
commit32f972a26a0066291873445088718deec3ed4233 (patch)
tree95f83e15d08ebca4ae4f377b0e359a2f7ce01671 /src/collection/boxed.rs
parentdf7c467005756433b2627b766bd086efda8689f4 (diff)
Impl Lock for LockCollection
Diffstat (limited to 'src/collection/boxed.rs')
-rw-r--r--src/collection/boxed.rs34
1 files changed, 34 insertions, 0 deletions
diff --git a/src/collection/boxed.rs b/src/collection/boxed.rs
index a12a690..1f068ec 100644
--- a/src/collection/boxed.rs
+++ b/src/collection/boxed.rs
@@ -15,6 +15,40 @@ fn contains_duplicates(l: &[&dyn RawLock]) -> bool {
.any(|window| std::ptr::eq(window[0], window[1]))
}
+unsafe impl<L: Lockable + Send + Sync> RawLock for BoxedLockCollection<L> {
+ unsafe fn lock(&self) {
+ for lock in self.locks() {
+ lock.lock();
+ }
+ }
+
+ unsafe fn try_lock(&self) -> bool {
+ utils::ordered_try_lock(self.locks())
+ }
+
+ unsafe fn unlock(&self) {
+ for lock in self.locks() {
+ lock.unlock();
+ }
+ }
+
+ unsafe fn read(&self) {
+ for lock in self.locks() {
+ lock.read();
+ }
+ }
+
+ unsafe fn try_read(&self) -> bool {
+ utils::ordered_try_read(self.locks())
+ }
+
+ unsafe fn unlock_read(&self) {
+ for lock in self.locks() {
+ lock.unlock_read();
+ }
+ }
+}
+
unsafe impl<L: Lockable> Lockable for BoxedLockCollection<L> {
type Guard<'g> = L::Guard<'g> where Self: 'g;