.Net 執行緒安全集合-有解無憂

.Net 提供了基于生產-消費模式的集合類，這些集合對多執行緒訪問安全，定義在System.Collections.Concurrent名稱空間中，這個名稱空間中包括基礎介面IProduceConsumerCollection，這個介面定義了執行緒安全集合的基本操作，這個名稱空間中還包括常用的集合：

BlockingCollection
ConcurrentBag
ConcurentDictionary<TKey,TValue>
ConcurrentQueue
ConcurentStack

在使用生產-消費模式時，我們經常使用兩個執行緒，在一個執行緒向集合添加資料，在另一個執行緒從集合中提取資料進行處理，我們可以使用實作IProduceConsumerCollection介面的集合，比如ConcurrentQueue等等，通常將從集合取資料的代碼放在一個無盡回圈中，如果集合中沒有資料就繼續回圈，很多情況下，我們希望如果集合中沒有資料，這個執行緒阻塞等待，直到有資料時再繼續，這時我們可以使用BlockingCollection，這個集合提供了Add(添加資料)和Take（阻塞獲取資料）方法，

下面是BlockingCollection的示例，這個集合類的Take方法可以從集合中獲取并去掉一個物件，當集合為空時，可以使執行緒處于阻塞狀態，

Console.WriteLine("--------------------------------");
Console.WriteLine("測驗一個執行緒向集合添加資料，另一個執行緒讀取資料，請輸入人名，輸入exit退出");
BlockingCollection<string> names=new BlockingCollection<string>();

Task.Run(() =>
{
    while (true)
    {
        var name = names.Take();
        Console.WriteLine("你好,"+name);
    }

});

var name = Console.ReadLine();
while (name!="exit")
{
    if(!string.IsNullOrEmpty(name))   names.Add(name);
    name = Console.ReadLine();
}

BlockingCollection的另一個功能是可以封裝其它的IProduceConsumerCollection集合，實作不同的添加和獲取順序，比如，如果在建構式中傳入ConcurrentQueue，添加和獲取就與佇列相同——“先進先出”，如果傳入ConcurrentStack，順序就與堆疊相同——“先進后出”，下面是示例代碼：

using System.Collections.Concurrent;

Console.WriteLine("--------------------------------");
Console.WriteLine("測驗BlockingCollection 和 ConcurrentQueue");

var queue = new ConcurrentQueue<string>();
var blockqueue= new BlockingCollection<string>(queue, 100);

Console.WriteLine("加入name1");
blockqueue.Add("name1");
Console.WriteLine("加入name2");
blockqueue.Add("name2");
Console.WriteLine("加入name3");
blockqueue.Add("name3");

Console.WriteLine(blockqueue.Take());
Console.WriteLine(blockqueue.Take());
Console.WriteLine(blockqueue.Take());

Console.WriteLine("--------------------------------");
Console.WriteLine("測驗BlockingCollection 和 ConcurrentStack");

var cq = new ConcurrentStack<string>();
var bc = new BlockingCollection<string>(cq, 100);

Console.WriteLine("加入name1");
bc.Add("name1");
Console.WriteLine("加入name2");
bc.Add("name2");
Console.WriteLine("加入name3");
bc.Add("name3");

Console.WriteLine(bc.Take());
Console.WriteLine(bc.Take());
Console.WriteLine(bc.Take());

ConcurrentBag需要特別說明一下，在“純生產-消費”場景中（一個執行緒要么向集合添加專案，要么從集合中獲取專案，但不能即添加又獲取），ConcurrentBag性能要比其他型別的集合慢，但在“混合生產-消費”場景中（一個執行緒即可以向集合添加專案，也可以獲取專案），ConcurrentBag的性能要比其它型別的集合快，

本文來自博客園，作者：尋找無名的特質，轉載請注明原文鏈接：https://www.cnblogs.com/zhenl/p/15768806.html

轉載請註明出處，本文鏈接：https://www.uj5u.com/net/412698.html

標籤：C#

上一篇：記一次 WinDbg 分析 .NET 某工廠MES系統記憶體泄漏分析

下一篇：MASA Framework - 整體設計思路