diff options
| author | Mica White <botahamec@gmail.com> | 2024-07-16 17:18:33 -0400 |
|---|---|---|
| committer | Mica White <botahamec@gmail.com> | 2024-07-17 16:37:21 -0400 |
| commit | 32f972a26a0066291873445088718deec3ed4233 (patch) | |
| tree | 95f83e15d08ebca4ae4f377b0e359a2f7ce01671 /src/collection/boxed.rs | |
| parent | df7c467005756433b2627b766bd086efda8689f4 (diff) | |
Impl Lock for LockCollection
Diffstat (limited to 'src/collection/boxed.rs')
| -rw-r--r-- | src/collection/boxed.rs | 34 |
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; |
