// Copyright 2014 The Rust Project Developers. See the COPYRIGHT // file at the top-level directory of this distribution and at // http://rust-lang.org/COPYRIGHT. // // Licensed under the Apache License, Version 2.0 or the MIT license // , at your // option. This file may not be copied, modified, or distributed // except according to those terms. use prelude::v1::*; use cell::UnsafeCell; use sys::sync as ffi; use mem; pub struct Mutex { inner: UnsafeCell } pub const MUTEX_INIT: Mutex = Mutex { inner: UnsafeCell { value: ffi::SRWLOCK_INIT } }; unsafe impl Send for Mutex {} unsafe impl Sync for Mutex {} #[inline] pub unsafe fn raw(m: &Mutex) -> ffi::PSRWLOCK { m.inner.get() } // So you might be asking why we're using SRWLock instead of CriticalSection? // // 1. SRWLock is several times faster than CriticalSection according to // benchmarks performed on both Windows 8 and Windows 7. // // 2. CriticalSection allows recursive locking while SRWLock deadlocks. The Unix // implementation deadlocks so consistency is preferred. See #19962 for more // details. // // 3. While CriticalSection is fair and SRWLock is not, the current Rust policy // is there there are no guarantees of fairness. impl Mutex { #[inline] pub unsafe fn lock(&self) { ffi::AcquireSRWLockExclusive(self.inner.get()) } #[inline] pub unsafe fn try_lock(&self) -> bool { ffi::TryAcquireSRWLockExclusive(self.inner.get()) != 0 } #[inline] pub unsafe fn unlock(&self) { ffi::ReleaseSRWLockExclusive(self.inner.get()) } #[inline] pub unsafe fn destroy(&self) { // ... } } pub struct ReentrantMutex { inner: UnsafeCell } unsafe impl Send for ReentrantMutex {} unsafe impl Sync for ReentrantMutex {} impl ReentrantMutex { pub unsafe fn uninitialized() -> ReentrantMutex { mem::uninitialized() } pub unsafe fn init(&mut self) { ffi::InitializeCriticalSection(self.inner.get()); } pub unsafe fn lock(&self) { ffi::EnterCriticalSection(self.inner.get()); } #[inline] pub unsafe fn try_lock(&self) -> bool { ffi::TryEnterCriticalSection(self.inner.get()) != 0 } pub unsafe fn unlock(&self) { ffi::LeaveCriticalSection(self.inner.get()); } pub unsafe fn destroy(&self) { ffi::DeleteCriticalSection(self.inner.get()); } }