使用ReaderWriterLock类实现多用户读/单用户写同步

使用ReaderWriterLock类实现多用户读/单用户写同步^[1]

2015-03-12

应用程序在访问资源时是进行读操作，写操作相对较少。为解决这一问题，C#提供了System.Threading.ReaderWriterLock类以适应多用户读/单用户写的场景。

该类可实现以下功能：如果资源未被写操作锁定，那么任何线程都可对该资源进行读操作锁定，并且对读操作锁数量没有限制，即多个线程可同时对该资源进行读操作锁定，以读取数据。如果资源未被添加任何读或写操作锁，那么一个且仅有一个线程可对该资源添加写操作锁定，以写入数据。简单的讲就是：读操作锁是共享锁，允许多个线程同时读取数据；写操作锁是独占锁，同一时刻，仅允许一个线程进行写操作。

代码如下：

using System;
using System.Threading;

namespace ProcessTest
{
    class Program
    {        
        //读、写操作锁
        static ReaderWriterLock rwl = new ReaderWriterLock();

        static void Main(string[] args)
        {
            //分别创建2个读操作线程，2个写操作线程，并启动
            Thread tr0 = new Thread(new ParameterizedThreadStart(Read));
            Thread tr1 = new Thread(new ParameterizedThreadStart(Read));
            Thread tr2 = new Thread(new ParameterizedThreadStart(Write));
            Thread tr3 = new Thread(new ParameterizedThreadStart(Write));

            tr0.Start("R0");
            tr1.Start("R1");
            tr2.Start("W2");
            tr3.Start("W3");

            //等待线程执行完毕
            tr0.Join();
            tr1.Join();
            tr2.Join();
            tr3.Join();

            System.Console.ReadKey();
        }

        //读数据
        static void Read(object state)
        {
            for (int i = 0; i < 3; i++)
            {
                try
                {
                    //申请读操作锁，如果在1000ms内未获取读操作锁，则放弃
                    rwl.AcquireReaderLock(1000);
                    Console.WriteLine("Begin Read，Thread = {0}", state);
                    Thread.Sleep(10);
                    Console.WriteLine("End Read，Thread = {0}", state);
                    //释放读操作锁
                    rwl.ReleaseReaderLock();
                }
                catch (ApplicationException)
                {
                    //获取读操作锁失败的处理
                }
            }
        }

        //写数据
        static void Write(object state)
        {
            for (int i = 0; i < 3; i++)
            {
                try
                {
                    //申请写操作锁，如果在1000ms内未获取写操作锁，则放弃
                    rwl.AcquireWriterLock(1000);
                    Console.WriteLine("Begin write，Thread = {0}", state);
                    Thread.Sleep(100);
                    Console.WriteLine("End write，Thread = {0}", state);
                    //释放写操作锁
                    rwl.ReleaseWriterLock();
                }
                catch (ApplicationException)
                {
                    //获取写操作锁失败
                }
            }
        }
    }
}

结果如下：

参考：

[1] C#多线程编程之：使用ReaderWriterLock类实现多用户读/单用户写同步

[2] 归纳一下:C#线程同步的几种方法