根據(jù) .NET 官方文檔的定義：ConcurrentDictionary<TKey,TValue>?Class?表示可由多個線程同時訪問的線程安全的鍵/值對集合。這也是我們在并發(fā)任務(wù)中比較常用的一個類型，但它真的是絕對線程安全的嗎？

仔細(xì)閱讀官方文檔，我們會發(fā)現(xiàn)在文檔的底部線程安全性小節(jié)里這樣描述：

ConcurrentDictionary<TKey,TValue>?的所有公共和受保護(hù)的成員都是線程安全的，可從多個線程并發(fā)使用。但是，通過一個由?ConcurrentDictionary<TKey,TValue>?實現(xiàn)的接口的成員（包括擴(kuò)展方法）訪問時，不保證其線程安全性，并且可能需要由調(diào)用方進(jìn)行同步。

也就是說，調(diào)用 ConcurrentDictionary 本身的方法和屬性可以保證都是線程安全的。但是由于 ConcurrentDictionary 實現(xiàn)了一些接口（例如 ICollection、IEnumerable 和 IDictionary 等），使用這些接口的成員（或者這些接口的擴(kuò)展方法）不能保證其線程安全性。System.Linq.Enumerable.ToList?方法就是其中的一個例子，該方法是?IEnumerable?的一個擴(kuò)展方法，在 ConcurrentDictionary 實例上使用該方法，當(dāng)它被其它線程改變時可能拋出?System.ArgumentException?異常。下面是一個簡單的示例：

static void Main(string[] args) {var cd = new ConcurrentDictionary<int, int>();Task.Run(() =>{var random = new Random();while (true){var value = random.Next(10000);cd.AddOrUpdate(value, value, (key, oldValue) => value);}});while (true){cd.ToList(); //調(diào)用 System.Linq.Enumerable.ToList，拋出 System.ArgumentException 異常} }

System.Linq.Enumerable.ToList?擴(kuò)展方法：

發(fā)生異常是因為擴(kuò)展方法?ToList?中調(diào)用了?List?的構(gòu)造函數(shù)，該構(gòu)造函數(shù)接收一個?IEnumerable<T>?類型的參數(shù)，且該構(gòu)造函數(shù)中有一個對?ICollection<T>?的優(yōu)化（由 ConcurrentDictionary 實現(xiàn)的）。

System.Collections.Generic.List<T>?構(gòu)造函數(shù)：

在?List?的構(gòu)造函數(shù)中，首先通過調(diào)用?Count?獲取字典的大小，然后以該大小初始化數(shù)組，最后調(diào)用?CopyTo?將所有?KeyValuePair?項從字典復(fù)制到該數(shù)組。因為字典是可以由多個線程改變的，在調(diào)用?Count?后且調(diào)用?CopyTo?前，字典的大小可以增加或者減少。當(dāng)?ConcurrentDictionary?試圖訪問數(shù)組超出其邊界時，將引發(fā)?ArgumentException?異常。

ConcurrentDictionary<TKey,TValue> 中實現(xiàn)的 ICollection.CopyTo 方法：

---

如果您只需要一個包含字典所有項的單獨集合，可以通過調(diào)用?ConcurrentDictionary.ToArray?方法來避免此異常。它完成類似的操作，但是操作之前先獲取了字典的所有內(nèi)部鎖，保證了線程安全性。

注意，不要將此方法與?System.Linq.Enumerable.ToArray?擴(kuò)展方法混淆，調(diào)用?Enumerable.ToArray?像?Enumerable.ToList?一樣，可能引發(fā)?System.ArgumentException?異常。

看下面的代碼中：

static void Main(string[] args) {var cd = new ConcurrentDictionary<int, int>();Task.Run(() =>{var random = new Random();while (true){var value = random.Next(10000);cd.AddOrUpdate(value, value, (key, oldValue) => value);}});while (true){cd.ToArray(); //ConcurrentDictionary.ToArray, OK.} }

此時調(diào)用?ConcurrentDictionary.ToArray，而不是調(diào)用?Enumerable.ToArray，因為后者是一個擴(kuò)展方法，前者重載解析的優(yōu)先級高于后者。所以這段代碼不會拋出異常。

但是，如果通過字典實現(xiàn)的接口（繼承自 IEnumerable）使用字典，將會調(diào)用?Enumerable.ToArray?方法并拋出異常。例如，下面的代碼顯式地將?ConcurrentDictionary?實例分配給一個?IDictionary?變量：

static void Main(string[] args) {System.Collections.Generic.IDictionary<int, int> cd = new ConcurrentDictionary<int, int>();Task.Run(() =>{var random = new Random();while (true){var value = random.Next(10000);cd[value] = value;}});while (true){cd.ToArray(); //調(diào)用 System.Linq.Enumerable.ToArray，拋出 System.ArgumentException 異常} }

此時調(diào)用?Enumerable.ToArray，就像調(diào)用?Enumerable.ToList?時一樣，引發(fā)了?System.ArgumentException?異常。

總結(jié)

正如官方文檔上所說的那樣，ConcurrentDictionary 的所有公共和受保護(hù)的成員都是線程安全的，可從多個線程并發(fā)調(diào)用。但是，通過一個由 ConcurrentDictionary 實現(xiàn)的接口的成員（包括擴(kuò)展方法）訪問時，并不是線程安全的，此時要特別注意。

如果需要一個包含字典所有項的單獨集合，可以通過調(diào)用?ConcurrentDictionary.ToArray?方法得到，千萬不能使用擴(kuò)展方法?ToList，因為它不是線程安全的。

---

參考：

http://blog.i3arnon.com/2018/01/16/concurrent-dictionary-tolist/? ConcurrentDictionary Is Not Always Thread-Safe?

https://docs.microsoft.com/en-us/dotnet/api/system.collections.concurrent.concurrentdictionary-2? ConcurrentDictionary<TKey,TValue> Class

作者 ：技術(shù)譯民
出品 ：技術(shù)譯站（https://ITTranslator.cn/）

END

總結(jié)

以上是生活随笔為你收集整理的C# 中 ConcurrentDictionary 一定线程安全吗？的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。