#region Copyright 2010-2014 by Roger Knapp, Licensed under the Apache License, Version 2.0 /* 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. */ #endregion using System; using System.Threading; namespace CSharpTest.Net.Synchronization { /// /// wraps the reader/writer lock around Monitor /// public class ExclusiveLocking : ILockStrategy { /// The writer version int _writeVersion; void IDisposable.Dispose() { } /// /// Returns true if the lock was successfully obtained within the timeout specified /// public bool TryRead(int timeout) { return Monitor.TryEnter(this, timeout); } /// /// Releases a read lock /// public void ReleaseRead() { Monitor.Exit(this); } /// Changes every time a write lock is aquired. If WriteVersion == 0, no write locks have been issued. public int WriteVersion { get { return _writeVersion; } } /// /// Returns true if the lock was successfully obtained within the timeout specified /// public bool TryWrite(int timeout) { if (Monitor.TryEnter(this, timeout)) { _writeVersion++; return true; } return false; } /// /// Releases a writer lock /// public void ReleaseWrite() { Monitor.Exit(this); } /// /// Returns a reader lock that can be elevated to a write lock /// public ReadLock Read() { return ReadLock.Acquire(this, -1); } /// /// Returns a reader lock that can be elevated to a write lock /// /// public ReadLock Read(int timeout) { return ReadLock.Acquire(this, timeout); } /// /// Returns a read and write lock /// public WriteLock Write() { return WriteLock.Acquire(this, -1); } /// /// Returns a read and write lock /// /// public WriteLock Write(int timeout) { return WriteLock.Acquire(this, timeout); } } }