diff options
author | Theodore Dubois <tblodt@icloud.com> | 2019-04-28 06:24:58 -0700 |
---|---|---|
committer | Christian Duerr <chrisduerr@users.noreply.github.com> | 2019-04-28 13:24:58 +0000 |
commit | dbd8538762ef8968a493e1bf996e8693479ca783 (patch) | |
tree | 32ac2a6a5e01238a272d4ba534551d2e42903c7a /alacritty_terminal/src/sync.rs | |
parent | 9c6d12ea2c863ba76015bdedc00db13b7307725a (diff) | |
download | alacritty-dbd8538762ef8968a493e1bf996e8693479ca783.tar.gz alacritty-dbd8538762ef8968a493e1bf996e8693479ca783.zip |
Split alacritty into a separate crates
The crate containing the entry point is called alacritty, and the crate
containing everything else is called alacritty_terminal.
Diffstat (limited to 'alacritty_terminal/src/sync.rs')
-rw-r--r-- | alacritty_terminal/src/sync.rs | 44 |
1 files changed, 44 insertions, 0 deletions
diff --git a/alacritty_terminal/src/sync.rs b/alacritty_terminal/src/sync.rs new file mode 100644 index 00000000..0fcd0862 --- /dev/null +++ b/alacritty_terminal/src/sync.rs @@ -0,0 +1,44 @@ +// Copyright 2016 Joe Wilm, The Alacritty Project Contributors +// +// Licensed under the Apache License, Version 2.0 (the "License"); +// you may not use this file except in compliance with the License. +// You may obtain a copy of the License at +// +// http://www.apache.org/licenses/LICENSE-2.0 +// +// Unless required by applicable law or agreed to in writing, software +// distributed under the License is distributed on an "AS IS" BASIS, +// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +// See the License for the specific language governing permissions and +// limitations under the License. + +//! Synchronization types +//! +//! Most importantly, a fair mutex is included +use parking_lot::{Mutex, MutexGuard}; + +/// A fair mutex +/// +/// Uses an extra lock to ensure that if one thread is waiting that it will get +/// the lock before a single thread can re-lock it. +pub struct FairMutex<T> { + /// Data + data: Mutex<T>, + /// Next-to-access + next: Mutex<()>, +} + +impl<T> FairMutex<T> { + /// Create a new fair mutex + pub fn new(data: T) -> FairMutex<T> { + FairMutex { data: Mutex::new(data), next: Mutex::new(()) } + } + + /// Lock the mutex + pub fn lock(&self) -> MutexGuard<'_, T> { + // Must bind to a temporary or the lock will be freed before going + // into data.lock() + let _next = self.next.lock(); + self.data.lock() + } +} |