如何使用C#读写锁ReaderWriterLockSlim

更新时间：2022年04月27日 14:26:12 作者：cnn237111

这篇文章向大家介绍了读写锁ReaderWriterLockSlim，其优点就是多个线程可以同时读取该对象，要了解更多读写锁的知识，仔细阅读下文吧

读写锁的概念很简单，允许多个线程同时获取读锁，但同一时间只允许一个线程获得写锁，因此也称作共享-独占锁。在C#中，推荐使用ReaderWriterLockSlim类来完成读写锁的功能。
某些场合下，对一个对象的读取次数远远大于修改次数，如果只是简单的用lock方式加锁，则会影响读取的效率。而如果采用读写锁，则多个线程可以同时读取该对象，只有等到对象被写入锁占用的时候，才会阻塞。

简单的说，当某个线程进入读取模式时，此时其他线程依然能进入读取模式，假设此时一个线程要进入写入模式，那么他不得不被阻塞。直到读取模式退出为止。

同样的，如果某个线程进入了写入模式，那么其他线程无论是要写入还是读取，都是会被阻塞的。

进入写入/读取模式有2种方法：

EnterReadLock尝试进入写入模式锁定状态。
TryEnterReadLock(Int32) 尝试进入读取模式锁定状态，可以选择整数超时时间。
EnterWriteLock 尝试进入写入模式锁定状态。
TryEnterWriteLock(Int32) 尝试进入写入模式锁定状态，可以选择超时时间。

退出写入/读取模式有2种方法：

ExitReadLock 减少读取模式的递归计数，并在生成的计数为 0（零）时退出读取模式。
ExitWriteLock 减少写入模式的递归计数，并在生成的计数为 0（零）时退出写入模式。
下面演示一下用法：

public class Program
  {
    static private ReaderWriterLockSlim rwl = new ReaderWriterLockSlim();
    static void Main(string[] args)
    {
      Thread t_read1 = new Thread(new ThreadStart(ReadSomething));
      t_read1.Start();
      Console.WriteLine("{0} Create Thread ID {1} , Start ReadSomething", DateTime.Now.ToString("hh:mm:ss fff"), t_read1.GetHashCode());
      Thread t_read2 = new Thread(new ThreadStart(ReadSomething));
      t_read2.Start();
      Console.WriteLine("{0} Create Thread ID {1} , Start ReadSomething", DateTime.Now.ToString("hh:mm:ss fff"), t_read2.GetHashCode());
      Thread t_write1 = new Thread(new ThreadStart(WriteSomething));
      t_write1.Start();
      Console.WriteLine("{0} Create Thread ID {1} , Start WriteSomething", DateTime.Now.ToString("hh:mm:ss fff"), t_write1.GetHashCode());
    }
    static public void ReadSomething()
    {
      Console.WriteLine("{0} Thread ID {1} Begin EnterReadLock...", DateTime.Now.ToString("hh:mm:ss fff"), Thread.CurrentThread.GetHashCode());
      rwl.EnterReadLock();
      try
      {
        Console.WriteLine("{0} Thread ID {1} reading sth...", DateTime.Now.ToString("hh:mm:ss fff"), Thread.CurrentThread.GetHashCode());
        Thread.Sleep(5000);//模拟读取信息
        Console.WriteLine("{0} Thread ID {1} reading end.", DateTime.Now.ToString("hh:mm:ss fff"), Thread.CurrentThread.GetHashCode());
      }
      finally
      {
        rwl.ExitReadLock();
        Console.WriteLine("{0} Thread ID {1} ExitReadLock...", DateTime.Now.ToString("hh:mm:ss fff"), Thread.CurrentThread.GetHashCode());
      }
    }
    static public void WriteSomething()
    {
      Console.WriteLine("{0} Thread ID {1} Begin EnterWriteLock...", DateTime.Now.ToString("hh:mm:ss fff"), Thread.CurrentThread.GetHashCode());
      rwl.EnterWriteLock();
      try
      {
        Console.WriteLine("{0} Thread ID {1} writing sth...", DateTime.Now.ToString("hh:mm:ss fff"), Thread.CurrentThread.GetHashCode());
        Thread.Sleep(10000);//模拟写入信息
        Console.WriteLine("{0} Thread ID {1} writing end.", DateTime.Now.ToString("hh:mm:ss fff"), Thread.CurrentThread.GetHashCode());
      }
      finally
      {
        rwl.ExitWriteLock();
        Console.WriteLine("{0} Thread ID {1} ExitWriteLock...", DateTime.Now.ToString("hh:mm:ss fff"), Thread.CurrentThread.GetHashCode());
      }
    }
  }

可以看到3号线程和4号线程能够同时进入读模式，而5号线程过了5秒钟后（即3,4号线程退出读锁后），才能进入写模式。
把上述代码修改一下，先开启2个写模式的线程，然后在开启读模式线程，代码如下：

static void Main(string[] args)
    {
      Thread t_write1 = new Thread(new ThreadStart(WriteSomething));
      t_write1.Start();
      Console.WriteLine("{0} Create Thread ID {1} , Start WriteSomething", DateTime.Now.ToString("hh:mm:ss fff"), t_write1.GetHashCode());
      Thread t_write2 = new Thread(new ThreadStart(WriteSomething));
      t_write2.Start();
      Console.WriteLine("{0} Create Thread ID {1} , Start WriteSomething", DateTime.Now.ToString("hh:mm:ss fff"), t_write2.GetHashCode());
      Thread t_read1 = new Thread(new ThreadStart(ReadSomething));
      t_read1.Start();
      Console.WriteLine("{0} Create Thread ID {1} , Start ReadSomething", DateTime.Now.ToString("hh:mm:ss fff"), t_read1.GetHashCode());
      Thread t_read2 = new Thread(new ThreadStart(ReadSomething));
      t_read2.Start();
      Console.WriteLine("{0} Create Thread ID {1} , Start ReadSomething", DateTime.Now.ToString("hh:mm:ss fff"), t_read2.GetHashCode());
    }

结果如下：

可以看到，3号线程和4号线程都要进入写模式，但是3号线程先占用写入锁，因此4号线程不得不等了10s后才进入。5号线程和6号线程需要占用读取锁，因此等4号线程退出写入锁后才能继续下去。
TryEnterReadLock和TryEnterWriteLock可以设置一个超时时间，运行到这句话的时候，线程会阻塞在此，如果此时能占用锁，那么返回true，如果到超时时间还未占用锁，那么返回false，放弃锁的占用，直接继续执行下面的代码。

EnterUpgradeableReadLock

ReaderWriterLockSlim类提供了可升级读模式，这种方式和读模式的区别在于它还有通过调用 EnterWriteLock 或 TryEnterWriteLock 方法升级为写入模式。因为每次只能有一个线程处于可升级模式。进入可升级模式的线程，不会影响读取模式的线程，即当一个线程进入可升级模式，任意数量线程可以同时进入读取模式，不会阻塞。如果有多个线程已经在等待获取写入锁，那么运行EnterUpgradeableReadLock将会阻塞，直到那些线程超时或者退出写入锁。
下面代码演示了如何在可升级读模式下，升级到写入锁。

static public void UpgradeableRead()
    {
      Console.WriteLine("{0} Thread ID {1} Begin EnterUpgradeableReadLock...", DateTime.Now.ToString("hh:mm:ss fff"), Thread.CurrentThread.GetHashCode());
      rwl.EnterUpgradeableReadLock();
      try
      {
        Console.WriteLine("{0} Thread ID {1} doing sth...", DateTime.Now.ToString("hh:mm:ss fff"), Thread.CurrentThread.GetHashCode());
        Console.WriteLine("{0} Thread ID {1} Begin EnterWriteLock...", DateTime.Now.ToString("hh:mm:ss fff"), Thread.CurrentThread.GetHashCode());
        rwl.EnterWriteLock();
        try
        {
          Console.WriteLine("{0} Thread ID {1} writing sth...", DateTime.Now.ToString("hh:mm:ss fff"), Thread.CurrentThread.GetHashCode());
          Thread.Sleep(10000);//模拟写入信息
          Console.WriteLine("{0} Thread ID {1} writing end.", DateTime.Now.ToString("hh:mm:ss fff"), Thread.CurrentThread.GetHashCode());
        }
        finally
        {
          rwl.ExitWriteLock();
          Console.WriteLine("{0} Thread ID {1} ExitWriteLock...", DateTime.Now.ToString("hh:mm:ss fff"), Thread.CurrentThread.GetHashCode());
        }
        Thread.Sleep(10000);//模拟读取信息
        Console.WriteLine("{0} Thread ID {1} doing end.", DateTime.Now.ToString("hh:mm:ss fff"), Thread.CurrentThread.GetHashCode());
      }
      finally
      {
        rwl.ExitUpgradeableReadLock();
        Console.WriteLine("{0} Thread ID {1} ExitUpgradeableReadLock...", DateTime.Now.ToString("hh:mm:ss fff"), Thread.CurrentThread.GetHashCode());
      }
    }

读写锁对于性能的影响是明显的。
下面测试代码：

public class Program
  {
    static private ReaderWriterLockSlim rwl = new ReaderWriterLockSlim();
    static void Main(string[] args)
    {
      Stopwatch sw = new Stopwatch();
      sw.Start();
      List<Task> lstTask = new List<Task>();
      for (int i = 0; i < 500; i++)
      {
        if (i % 25 != 0)
        {
          var t = Task.Factory.StartNew(ReadSomething);
          lstTask.Add(t);
        }
        else
        {
          var t = Task.Factory.StartNew(WriteSomething);
          lstTask.Add(t);
        }
      }
      Task.WaitAll(lstTask.ToArray());
      sw.Stop();
      Console.WriteLine("使用ReaderWriterLockSlim方式，耗时：" + sw.Elapsed);
      sw.Restart();
      lstTask = new List<Task>();
      for (int i = 0; i < 500; i++)
      {
        if (i % 25 != 0)
        {
          var t = Task.Factory.StartNew(ReadSomething_lock);
          lstTask.Add(t);
        }
        else
        {
          var t = Task.Factory.StartNew(WriteSomething_lock);
          lstTask.Add(t);
        }
      }
      Task.WaitAll(lstTask.ToArray());
      sw.Stop();
      Console.WriteLine("使用lock方式，耗时：" + sw.Elapsed);
    }
    static private object _lock1 = new object();
    static public void ReadSomething_lock()
    {
      lock (_lock1)
      {
        //Console.WriteLine("{0} Thread ID {1} reading sth...", DateTime.Now.ToString("hh:mm:ss fff"), Thread.CurrentThread.GetHashCode());
        Thread.Sleep(10);//模拟读取信息
        //Console.WriteLine("{0} Thread ID {1} reading end.", DateTime.Now.ToString("hh:mm:ss fff"), Thread.CurrentThread.GetHashCode());
      }
    }
    static public void WriteSomething_lock()
    {
      lock (_lock1)
      {
        //Console.WriteLine("{0} Thread ID {1} writing sth...", DateTime.Now.ToString("hh:mm:ss fff"), Thread.CurrentThread.GetHashCode());
        Thread.Sleep(100);//模拟写入信息
        //Console.WriteLine("{0} Thread ID {1} writing end.", DateTime.Now.ToString("hh:mm:ss fff"), Thread.CurrentThread.GetHashCode());
      }
    }
    static public void ReadSomething()
    {
      rwl.EnterReadLock();
      try
      {
        //Console.WriteLine("{0} Thread ID {1} reading sth...", DateTime.Now.ToString("hh:mm:ss fff"), Thread.CurrentThread.GetHashCode());
        Thread.Sleep(10);//模拟读取信息
        //Console.WriteLine("{0} Thread ID {1} reading end.", DateTime.Now.ToString("hh:mm:ss fff"), Thread.CurrentThread.GetHashCode());
      }
      finally
      {
        rwl.ExitReadLock();
      }
    }
    static public void WriteSomething()
    {
      rwl.EnterWriteLock();
      try
      {
        //Console.WriteLine("{0} Thread ID {1} writing sth...", DateTime.Now.ToString("hh:mm:ss fff"), Thread.CurrentThread.GetHashCode());
        Thread.Sleep(100);//模拟写入信息
        //Console.WriteLine("{0} Thread ID {1} writing end.", DateTime.Now.ToString("hh:mm:ss fff"), Thread.CurrentThread.GetHashCode());
      }
      finally
      {
        rwl.ExitWriteLock();
      }
    }
  }

上述代码，就500个Task，每个Task占用一个线程池线程，其中20个写入线程和480个读取线程，模拟操作。其中读取数据花10ms，写入操作花100ms，分别测试了对于lock方式和ReaderWriterLockSlim方式。可以做一个估算，对于ReaderWriterLockSlim，假设480个线程同时读取，那么消耗10ms，20个写入操作占用2000ms，因此所消耗时间2010ms，而对于普通的lock方式，由于都是独占性的，因此480个读取操作占时间4800ms+20个写入操作2000ms=6800ms。运行结果显示了性能提升明显。

以上是本文的全部内容，希望对大家熟练应用读写锁ReaderWriterLockSlim有所帮助。

您可能感兴趣的文章:

C#
读写锁

C#自定义画刷原理解析
这篇文章主要为大家详细介绍了C#自定义画刷原理，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
2022-08-08
C#实现Socket服务器及多客户端连接的方式
这篇文章介绍了C#实现Socket服务器及多客户端连接的方式，文中通过示例代码介绍的非常详细。对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下
2022-01-01
c#判断网络连接状态
有时我们要不停的判断网络的连接状态，比如服务器网络连接是否正常等，下面就简单介绍我的判断方法
2014-01-01
unity将图片转换成字体的方法
这篇文章主要为大家详细介绍了unity将图片转换成字体的方法，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
2020-04-04
C#高效实现集合批量添加与删除操作
在C#中,对集合进行批量操作通常涉及使用集合类型提供的方法和特性,以及可能的循环或LINQ查询来高效地处理大量数据,本文整理了一些常见的方法和技巧,需要的可以了解下
2025-01-01
打开一个Unity工程步骤
这篇文章讲述了如何打开一个Unity工程,包含详细的图文介绍的步骤,希望本文对你有所帮助
2021-06-06
WinForm窗体调用WCF服务窗体卡死问题
在Winform窗体中调用部署在其他服务器中的WCF服务时，由于调用服务需要一定时延，因此窗体在这段时间一直卡住不能进行其他操作
2012-12-12
C#中Hashtable和Dictionary的区别与用法示例
由于 Hashtable 和 Dictionary 同时存在, 在使用场景上必然存在选择性, 并不任何时刻都能相互替代。所以这篇文章主要给大家介绍了关于C#中Hashtable和Dictionary区别的相关资料,需要的朋友可以参考下
2021-05-05
C# 中this关键字的主要作用
this 关键字在C#中主要用于引用当前对象,区分字段与局部变量,调用其他构造函数以及传递当前对象给其他方法或构造函数,本文重点介绍C# this关键字的作用,感兴趣的朋友一起看看吧
2024-02-02
如何使用C#串口通讯实现数据的发送和接收
本文详细介绍了如何使用C#实现基于串口通讯的数据发送和接收,通过SerialPort类,我们可以轻松实现串口通讯,并结合事件机制实现数据的传递和处理,感兴趣的朋友一起看看吧
2025-03-03

如何使用C#读写锁ReaderWriterLockSlim

相关文章

最新评论

大家感兴趣的内容

最近更新的内容

常用在线小工具