设为首页 加入收藏

TOP

C#读写锁ReaderWriterLockSlim的使用(一)
2015-02-02 14:43:13 来源: 作者: 【 】 浏览:42
Tags:读写 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());
? ? ? ? ? ? }
? ? ? ? }
? ? }


C#读写锁ReaderWriterLockSlim的使用


可以看到3号线程和4号线程能够同时进入读模式,而5号线程过了5秒钟后(即3,4号线程退出读锁后),才能进入写模式。


把上述代码修改一下,先开启2个写模式的线程,然后在开启读模式线程,代码如下:


? ? ? {
? ? ? ? ? ? Thread t_write1 = new Thread(new ThreadStart(WriteSomething));
? ? ? ? ? ? t_write1.Start();
? ? ? ? ? ? Console.WriteLine("{0} Create Thread ID {1} , Start WriteS

首页 上一页 1 2 3 下一页 尾页 1/3/3
】【打印繁体】【投稿】【收藏】 【推荐】【举报】【评论】 【关闭】 【返回顶部
分享到: 
上一篇C#中Interlocked不能保证的事情 下一篇Python使用xinetd处理多客户端

评论

帐  号: 密码: (新用户注册)
验 证 码:
表  情:
内  容: