當前位置：首頁 > 编程语言 > C# >内容正文

C#

C# 多线程并发锁模式-总结

發布時間：2025/5/22 C# 42 豆豆

生活随笔收集整理的這篇文章主要介紹了 C# 多线程并发锁模式-总结小編覺得挺不錯的,現在分享給大家,幫大家做個參考.

開篇：

互斥還是lock Monitor Mutex 模式！

Muex Monitor lock AutoEventSet ManualEventSet?

后續的

ReaderWriterLock

ReaderWriterLockSlim 類

表示用于管理資源訪問的鎖定狀態，可實現多線程讀取或進行獨占式寫入訪問。

使用?ReaderWriterLockSlim?來保護由多個線程讀取但每次只采用一個線程寫入的資源。?ReaderWriterLockSlim?允許多個線程均處于讀取模式，允許一個線程處于寫入模式并獨占鎖定狀態，同時還允許一個具有讀取權限的線程處于可升級的讀取模式，在此模式下線程無需放棄對資源的讀取權限即可升級為寫入模式。

注意?ReaderWriterLockSlim 類似于 ReaderWriterLock，只是簡化了遞歸、升級和降級鎖定狀態的規則。 ReaderWriterLockSlim 可避免多種潛在的死鎖情況。此外，ReaderWriterLockSlim 的性能明顯優于 ReaderWriterLock。建議在所有新的開發工作中使用 ReaderWriterLockSlim。

以上引用自MSDN

C# 線程手冊第三章使用線程 ReaderWriterLock 類

2012-02-07 21:53 by DanielWise,?4166?閱讀,?1?評論,?收藏,?編輯

一個ReaderWriterLock 類定義一個實現單寫多讀語義的鎖。這個類通常用在能被多個線程讀取但是僅能被一個線程寫入的文件操作時使用。下面是ReaderWriterLock類中的四個主要方法：

? a. AcquireReaderLock(): 這個重載方法獲取一個讀者鎖，接受一個整型或者TimeSpan類型的timeout 值。timeout是一個檢測死鎖的利器。

? b. AcquireWriterLock():? 這個重載方法獲取一個寫者鎖，接受一個整型或者TimeSpan類型的timeout 值。

? c. ReleaseReaderLock(): 釋放讀者鎖。

? d. ReleaseWriterLock(): 釋放寫者鎖。

使用ReaderWriterLock類可以讓多線程安全地進行數據并發讀取。只有當線程正在更新的數據鎖定。讀者線程可以再沒有寫者擁有鎖的時候獲得鎖。寫者線程可以再沒有讀者線程或者寫者線程擁有鎖的時候獲得鎖。

下面的列表ReadeWriteLock.cs, 描述了如何使用ReaderWriterLock()鎖：

/************************************* /* copyright (c) 2012 daniel dong* * author：daniel dong* blog： www.cnblogs.com/danielwise* email： guofoo@163.com* */using System; using System.Collections.Generic; using System.Text; using System.Threading;namespace ReadWriteLock {public class ReadWrite{private ReaderWriterLock rwl;private int x;private int y;public ReadWrite(){rwl = new ReaderWriterLock();}public void ReadInts(ref int a, ref int b){rwl.AcquireReaderLock(Timeout.Infinite);try{a = this.x;b = this.y;}finally{rwl.ReleaseReaderLock();}}public void WriteInts(int a, int b){rwl.AcquireWriterLock(Timeout.Infinite);try{this.x = a;this.y = b;Console.WriteLine("x = " + this.x+ " y = " + this.y+ " ThreadID = " + Thread.CurrentThread.GetHashCode());}finally{rwl.ReleaseWriterLock();}}}public class RWApp{private ReadWrite rw = new ReadWrite();public static void Main(string[] args){RWApp e = new RWApp();//Writer ThreadsThread wt1 = new Thread(new ThreadStart(e.Write));wt1.Start();Thread wt2 = new Thread(new ThreadStart(e.Write));wt2.Start();//Reader ThreadsThread rt1 = new Thread(new ThreadStart(e.Read));rt1.Start();Thread rt2 = new Thread(new ThreadStart(e.Read));rt2.Start();Console.ReadLine();}private void Write(){int a = 10;int b = 11;Console.WriteLine("************** Write *************");for (int i = 0; i < 5; i++){this.rw.WriteInts(a++, b++);Thread.Sleep(1000);}}private void Read(){int a = 10;int b = 11;Console.WriteLine("************** Read *************");for (int i = 0; i < 5; i++){this.rw.ReadInts(ref a, ref b);Console.WriteLine("For i = " + i+ " a = " + a+ " b = " + b+ " TheadID = " + Thread.CurrentThread.GetHashCode());Thread.Sleep(1000);}}} }

ReadWriteLock 的輸出結果可能與下表類似：

在上面的列表中，線程wt1 和 wt2 是WriteInts()方法中獲得寫鎖的寫者線程，線程rt1 和 rt2 是在ReadInts()方法中獲得讀者鎖的讀者線程。在WriteInts()方法中，變量x 和 y 的值分別被改成a 和 b. 當線程wt1 或 wt2 通過調用AcquireWriterLock() 方法獲得一個寫者鎖后，那么直到這個線程通過調用ReleaseWriterLock()方法釋放鎖之前任何其他線程(包括讀者線程rt1 和 rt2)都不被允許訪問相應對象。這個行為與Monitors類似。在ReadInts()方法中，線程rt1 和 rt2 通過調用AcquireReaderLock()方法獲得讀者鎖，這兩個線程可以并發地訪問變量x 和 y. 直到讀者線程釋放它們的讀者鎖以后，寫者線程(wt1 和 wt2)才被允許訪問對應對象。只有讀者線程在獲得讀者鎖以后才可以并發地訪問。

Monitors類對于只想來讀數據而非寫數據來說過于“安全”了。Monitors 也有一些性能問題，對于只讀類型的訪問來說，性能瓶頸是可以避免的。ReaderWriterLock類通過允許任意數量的線程并發地讀取數據來提供一個解決數據讀-寫問題的完美方案。當線程更新數據時鎖住數據。當沒有寫者線程擁有鎖的時候寫者線程可以獲得鎖。寫者鎖可以在沒有讀者線程或者寫者線程擁有鎖的時候獲得鎖。因此，ReaderWriterLock 就像是一段關鍵部分代碼, 它也支持一個timeout 值，而這方面在檢測死鎖時非常有用。

??????1.幾種同步方法的區別

??????lock和Monitor是.NET用一個特殊結構實現的，Monitor對象是完全托管的、完全可移植的，并且在操作系統資源要求方面可能更為有效，同步速度較快，但不能跨進程同步。lock（Monitor.Enter和Monitor.Exit方法的封裝），主要作用是鎖定臨界區，使臨界區代碼只能被獲得鎖的線程執行。Monitor.Wait和Monitor.Pulse用于線程同步，類似信號操作，個人感覺使用比較復雜，容易造成死鎖。

??????互斥體Mutex和事件對象EventWaitHandler屬于內核對象，利用內核對象進行線程同步，線程必須要在用戶模式和內核模式間切換，所以一般效率很低，但利用互斥對象和事件對象這樣的內核對象，可以在多個進程中的各個線程間進行同步。

??????互斥體Mutex類似于一個接力棒，拿到接力棒的線程才可以開始跑，當然接力棒一次只屬于一個線程(Thread Affinity)，如果這個線程不釋放接力棒(Mutex.ReleaseMutex)，那么沒辦法，其他所有需要接力棒運行的線程都知道能等著看熱鬧。

??????EventWaitHandle 類允許線程通過發信號互相通信。通常，一個或多個線程在 EventWaitHandle 上阻止，直到一個未阻止的線程調用 Set 方法，以釋放一個或多個被阻止的線程。

??????2.什么時候需要鎖定

??????首先要理解鎖定是解決競爭條件的，也就是多個線程同時訪問某個資源，造成意想不到的結果。比如，最簡單的情況是，一個計數器，兩個線程同時加一，后果就是損失了一個計數，但相當頻繁的鎖定又可能帶來性能上的消耗，還有最可怕的情況死鎖。那么什么情況下我們需要使用鎖，什么情況下不需要呢？

??????1）只有共享資源才需要鎖定
??????只有可以被多線程訪問的共享資源才需要考慮鎖定，比如靜態變量，再比如某些緩存中的值，而屬于線程內部的變量不需要鎖定。?

??????2）多使用lock,少用Mutex
????? 如果你一定要使用鎖定，請盡量不要使用內核模塊的鎖定機制，比如.NET的Mutex，Semaphore，AutoResetEvent和 ManuResetEvent，使用這樣的機制涉及到了系統在用戶模式和內核模式間的切換，性能差很多，但是他們的優點是可以跨進程同步線程，所以應該清楚的了解到他們的不同和適用范圍。

????? 3）了解你的程序是怎么運行的
????? 實際上在web開發中大多數邏輯都是在單個線程中展開的，一個請求都會在一個單獨的線程中處理，其中的大部分變量都是屬于這個線程的，根本沒有必要考慮鎖定，當然對于ASP.NET中的Application對象中的數據，我們就要考慮加鎖了。

????? 4）把鎖定交給數據庫
????? 數據庫除了存儲數據之外，還有一個重要的用途就是同步，數據庫本身用了一套復雜的機制來保證數據的可靠和一致性，這就為我們節省了很多的精力。保證了數據源頭上的同步，我們多數的精力就可以集中在緩存等其他一些資源的同步訪問上了。通常，只有涉及到多個線程修改數據庫中同一條記錄時，我們才考慮加鎖。?

????? 5）業務邏輯對事務和線程安全的要求
????? 這條是最根本的東西，開發完全線程安全的程序是件很費時費力的事情，在電子商務等涉及金融系統的案例中，許多邏輯都必須嚴格的線程安全，所以我們不得不犧牲一些性能，和很多的開發時間來做這方面的工作。而一般的應用中，許多情況下雖然程序有競爭的危險，我們還是可以不使用鎖定，比如有的時候計數器少一多一，對結果無傷大雅的情況下，我們就可以不用去管它。

??????3.InterLocked類

????? Interlocked 類提供了同步對多個線程共享的變量的訪問的方法。如果該變量位于共享內存中，則不同進程的線程就可以使用該機制。互鎖操作是原子的，即整個操作是不能由相同變量上的另一個互鎖操作所中斷的單元。這在搶先多線程操作系統中是很重要的，在這樣的操作系統中，線程可以在從某個內存地址加載值之后但是在有機會更改和存儲該值之前被掛起。

????? 我們來看一個InterLock.Increment()的例子，該方法以原子的形式遞增指定變量并存儲結果，示例如下：

????class?InterLockedTest
????{
????????public?static?Int64?i?=?0;

????????public?static?void?Add()
????????{
????????????for?(int?i?=?0;?i?<?100000000;?i++)
????????????{
????????????????Interlocked.Increment(ref?InterLockedTest.i);
????????????????//InterLockedTest.i?=?InterLockedTest.i?+?1;
????????????}
????????}

????????public?static?void?Main(string[]?args)
????????{
????????????Thread?t1?=?new?Thread(new?ThreadStart(InterLockedTest.Add));
????????????Thread?t2?=?new?Thread(new?ThreadStart(InterLockedTest.Add));

????????????t1.Start();
????????????t2.Start();

????????????t1.Join();
????????????t2.Join();

????????????Console.WriteLine(InterLockedTest.i.ToString());
????????????Console.Read();
????????}
????}

????? 輸出結果200000000，如果InterLockedTest.Add()方法中用注釋掉的語句代替Interlocked.Increment() 方法，結果將不可預知，每次執行結果不同。InterLockedTest.Add()方法保證了加1操作的原子性，功能上相當于自動給加操作使用了 lock鎖。同時我們也注意到InterLockedTest.Add()用時比直接用+號加1要耗時的多，所以說加鎖資源損耗還是很明顯的。

????? 另外InterLockedTest類還有幾個常用方法，具體用法可以參考MSDN上的介紹。

???4.集合類的同步

????? .NET在一些集合類，比如Queue、ArrayList、HashTable和Stack，已經提供了一個供lock使用的對象SyncRoot。用 Reflector查看了SyncRoot屬性（Stack.SynchRoot略有不同）的源碼如下：

public?virtual?object?SyncRoot
{
????get
????{
????????if?(this._syncRoot?==?null)
????????{
????????????//如果_syncRoot和null相等，將new?object賦值給 _syncRoot
????????????//Interlocked.CompareExchange方法保證多個線程在使用 syncRoot時是線程安全的
????????????Interlocked.CompareExchange(ref?this._syncRoot,?new?object(),?null);
????????}
????????return?this._syncRoot;
????}
}

????? 這里要特別注意的是MSDN提到：從頭到尾對一個集合進行枚舉本質上并不是一個線程安全的過程。即使一個集合已進行同步，其他線程仍可以修改該集合，這將導致枚舉數引發異常。若要在枚舉過程中保證線程安全，可以在整個枚舉過程中鎖定集合，或者捕捉由于其他線程進行的更改而引發的異常。應該使用下面的代碼：

Queue使用lock示例

????? 還有一點需要說明的是，集合類提供了一個是和同步相關的方法Synchronized，該方法返回一個對應的集合類的wrapper類，該類是線程安全的，因為他的大部分方法都用lock關鍵字進行了同步處理。如HashTable的 Synchronized返回一個新的線程安全的HashTable實例，代碼如下：

????//在多線程環境中只要我們用下面的方式實例化HashTable就可以了
????Hashtable?ht?=?Hashtable.Synchronized(new?Hashtable());

????//以下代碼是.NET?Framework?Class?Library實現，增加對 Synchronized的認識
????[HostProtection(SecurityAction.LinkDemand,?Synchronization=true)]
????public?static?Hashtable?Synchronized(Hashtable?table)
????{
????????if?(table?==?null)
????????{
????????????throw?new?ArgumentNullException("table");
????????}
????????return?new?SyncHashtable(table);
????}

?
????//SyncHashtable的幾個常用方法，我們可以看到內部實現都加了lock關鍵字保證線程安全
????public?override?void?Add(object?key,?object?value)
????{
????????lock?(this._table.SyncRoot)
????????{
????????????this._table.Add(key,?value);
????????}
????}

????public?override?void?Clear()
????{
????????lock?(this._table.SyncRoot)
????????{
????????????this._table.Clear();
????????}
????}

????public?override?void?Remove(object?key)
????{
????????lock?(this._table.SyncRoot)
????????{
????????????this._table.Remove(key);
????????}
????}

????? 線程同步是一個非常復雜的話題，這里只是根據公司的一個項目把相關的知識整理出來，作為工作的一種總結。這些同步方法的使用場景是怎樣的？究竟有哪些細微的差別？還有待于進一步的學習和實踐。

總結

以上是生活随笔為你收集整理的C# 多线程并发锁模式-总结的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。

上一篇：你需要知道的Xcode Debug功能
下一篇：常用符号的英文名