#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 System.Threading.ReaderWriterLock lock, does not support read->write upgrades
///
public class ReaderWriterLocking : ILockStrategy
{
private readonly ReaderWriterLock _lock;
///
/// wraps the reader/writer lock
///
public ReaderWriterLocking() : this(new ReaderWriterLock())
{ }
///
/// wraps the reader/writer lock
///
public ReaderWriterLocking(ReaderWriterLock lck)
{ _lock = lck; }
void IDisposable.Dispose() { }
/// Changes every time a write lock is aquired. If WriteVersion == 0, no write locks have been issued.
public int WriteVersion { get { return _lock.WriterSeqNum; } }
///
/// Returns true if the lock was successfully obtained within the timeout specified
///
[System.Diagnostics.DebuggerNonUserCode]
public bool TryRead(int timeout)
{
try
{
_lock.AcquireReaderLock(timeout);
return true;
}
catch (ApplicationException)
{ return false; }
}
///
/// Releases a read lock
///
public void ReleaseRead()
{
_lock.ReleaseReaderLock();
}
///
/// Returns true if the lock was successfully obtained within the timeout specified
///
[System.Diagnostics.DebuggerNonUserCode]
public bool TryWrite(int timeout)
{
try
{
_lock.AcquireWriterLock(timeout);
return true;
}
catch (ApplicationException)
{ return false; }
}
///
/// Releases a writer lock
///
public void ReleaseWrite()
{
_lock.ReleaseWriterLock();
}
///
/// 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); }
}
}