#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); }
}
}