Welcome to ForkCan.com

ForkCan is all about sharing code in a social way.

Discuss, debate or argue with other devs about their or your own code.

Give other devs feedback or make a Fork (Make a better version of a shared code).

Rate the code, if you use the code mark it as used so others can see if the shared code is used by someone.

Help each other to be better devs and to be more productive.

Features not working yet:

Flag a post

QR Code

Tiny Url

http://4kcan.com/s/MjUw

Related Code

For the background story of this code, check my blog.

The purpose is to demonstrate an approach of using extension methods in combination with delegates and anonymous methods to hide repetitive code structures, which allows you to remove some "noise" from the code, making it more succinct.

In short, the longer code below is a class with extension methods for the ReaderWriterLockSlim class, allowing you to write relatively compact code for executing code under different locks, while still doing it in a safe manner that will exit the locks in case of exceptions and such. Example usage of the extension methods:

private static int GetFromQueueWithExtensions()  
{  
    int result = -1;  

    _lock.RunWithUpgradeableReadLock(() =>  
    {  
        if (sharedResource.Count > 0)  
        {  
            _lock.RunWithWriteLock(() =>  
            {  
                result = sharedResource.Dequeue();  
            });  
        }  
    });  

    return result;  
}

And the full class with extension methods follows below. OK, perhaps a bit on the long side but hey, it's documented :)

public static class ReaderWriterLockSlimExtensions
{
    /// <summary>
    /// Runs the given action under a read lock
    /// </summary>
    /// <param name="readerWriterLock">The <see cref="ReaderWriterLock"/> to use for locking.</param>
    /// <param name="action">The <see cref="Action"/> to peform</param>
    /// <param name="millisecondsTimeout">The timeout in milliseconds.</param>
    /// <remarks>If <paramref name="millisecondsTimeout"/> is -1, the method will wait infinitely for acquiring the lock.</remarks>
    public static void RunWithReadLock(this ReaderWriterLockSlim readerWriterLock, Action action, int millisecondsTimeout)
    {
        if (readerWriterLock.TryEnterReadLock(millisecondsTimeout))
        {
            try
            {
                action();
            }
            finally
            {
                readerWriterLock.ExitReadLock();
            }
        }
    }

    /// <summary>
    /// Runs the given code under a read lock.
    /// </summary>
    /// <param name="readerWriterLock">The <see cref="ReaderWriterLock"/> to use for locking.</param>
    /// <param name="action">The <see cref="Action"/> to peform</param>
    public static void RunWithReadLock(this ReaderWriterLockSlim readerWriterLock, Action action)
    {
        RunWithReadLock(readerWriterLock, action, -1);
    }


    /// <summary>
    /// Runs the given code under an upgradeable read lock.
    /// </summary>
    /// <param name="readerWriterLock">The <see cref="ReaderWriterLock"/> to use for locking.</param>
    /// <param name="action">The <see cref="Action"/> to peform</param>
    /// <param name="millisecondsTimeout">The timeout in milliseconds.</param>
    /// <remarks>If <paramref name="millisecondsTimeout"/> is -1, the method will wait infinitely for acquiring the lock.</remarks>
    public static void RunWithUpgradeableReadLock(this ReaderWriterLockSlim readerWriterLock, Action action, int millisecondsTimeout)
    {
        if (readerWriterLock.TryEnterUpgradeableReadLock(millisecondsTimeout))
        {
            try
            {
                action();
            }
            finally
            {
                readerWriterLock.ExitUpgradeableReadLock();
            }
        }
    }

    /// <summary>
    /// Runs the given code under an upgradeable read lock.
    /// </summary>
    /// <param name="readerWriterLock">The <see cref="ReaderWriterLock"/> to use for locking.</param>
    /// <param name="action">The <see cref="Action"/> to peform</param>
    public static void RunWithUpgradeableReadLock(this ReaderWriterLockSlim readerWriterLock, Action action)
    {
        RunWithUpgradeableReadLock(readerWriterLock, action, -1);
    }


    /// <summary>
    /// Runs the given code under a write lock.
    /// </summary>
    /// <param name="readerWriterLock">The <see cref="ReaderWriterLock"/> to use for locking.</param>
    /// <param name="action">The <see cref="Action"/> to peform</param>
    /// <param name="millisecondsTimeout">The timeout in milliseconds.</param>
    /// <remarks>If <paramref name="millisecondsTimeout"/> is -1, the method will wait infinitely for acquiring the lock.</remarks>
    public static void RunWithWriteLock(this ReaderWriterLockSlim readerWriterLock, Action action, int millisecondsTimeout)
    {
        if (readerWriterLock.TryEnterWriteLock(millisecondsTimeout))
        {
            try
            {
                action();
            }
            finally
            {
                readerWriterLock.ExitWriteLock();
            }
        }
    }

    /// <summary>
    /// Runs the given code under a write lock.
    /// </summary>
    /// <param name="readerWriterLock">The <see cref="ReaderWriterLock"/> to use for locking.</param>
    /// <param name="action">The <see cref="Action"/> to peform</param>
    public static void RunWithWriteLock(this ReaderWriterLockSlim readerWriterLock, Action action)
    {
        RunWithWriteLock(readerWriterLock, action, -1);
    }

}

Share: twitter | facebook   Action: used | fork | flag