中文字幕av专区_日韩电影在线播放_精品国产精品久久一区免费式_av在线免费观看网站

溫馨提示×

溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊×
其他方式登錄
點擊 登錄注冊 即表示同意《億速云用戶服務條款》

C#中神器類BlockingCollection怎么使用

發布時間:2023-02-28 13:48:17 來源:億速云 閱讀:127 作者:iii 欄目:開發技術

本文小編為大家詳細介紹“C#中神器類BlockingCollection怎么使用”,內容詳細,步驟清晰,細節處理妥當,希望這篇“C#中神器類BlockingCollection怎么使用”文章能幫助大家解決疑惑,下面跟著小編的思路慢慢深入,一起來學習新知識吧。

BlockingCollection簡單介紹

BlockingCollection 是一個線程安全集合類,可提供以下功能:

  • 實現制造者-使用者模式

  • 通過多線程并發添加和獲取項

  • 可選最大容量

  • 集合為空或已滿時通過插入和移除操作進行阻塞

  • 插入和移除“嘗試”操作不發生阻塞,或在指定時間段內發生阻塞

  • 封裝實現 IProducerConsumerCollection 的任何集合類型

  • 使用取消標記執行取消操作

  • 支持使用 foreach(在 Visual Basic 中,使用 For Each)的兩種枚舉:1. 只讀枚舉,2. 在枚舉項時將項移除的枚舉

起手式

BlockingCollection blockingCollection = new(1);

new 操作符里面的數字是實現了可選最大容量,超出就線程阻塞了,程序一直卡在哪里

先來個開胃菜 => 三句代碼實現線程阻塞

BlockingCollection<int> blockingCollection = new(1);
blockingCollection.Add(1);
blockingCollection.Add(2);

說明:因為限制隊列只能插入一條,第一條沒有消費掉,所以一直卡在插入第二條程序不會往下繼續運行實現了集合為空或已滿時通過插入和移除操作進行阻塞

正式開始前先分享一些多線程的知識點

Task類簡單介紹

Task 表面上是Thread但卻是對ThreadPool的封裝,控制和擴展性很強,對線程的延續,阻塞,取消,超時,比傳統的Thread和ThreadPool強

Queue類簡單介紹

隊列(Queue)代表了一個先進先出的對象集合。當您需要對各項進行先進先出的訪問時,則使用隊列。當您在列表中添加一項,稱為入隊,當您從列表中移除一項時,稱為出隊

接下來進入實際使用場景

場景一: 生產者=> 消費者

建議代碼還是要動手實現一下,不然體會不到一邊生產數據,同時還能取數據的神仙操作

int count = 0 ;
BlockingCollection<string> blockingCollection = new(1);
//生產者
Task.Factory.StartNew(() =>
{
 while (true)
 {
    blockingCollection.Add("String: " + count);
    count++;
    if (count > 10)
    {
     blockingCollection.CompleteAdding();
    }
 }
});

//消費者
Task.Factory.StartNew(() =>
{
 foreach (var element in blockingCollection.GetConsumingEnumerable())
 {
  Thread.Sleep(1000);
  ("Work: " + element).Dump();//Dump 為工具Linq的功能
 }
});

上面的代碼中這個方法GetConsumingEnumerable很重要,它可以在BlockingCollection集合有數據的時候取數據,沒有的話停止取,可以達到監測的效果

這個案例實現了如下功能:

  • 多線程并發添加和獲取項

  • 生產者和消費者模式

  • 使用取消標記執行取消操作(讓生產者知道我們已經不需要你工作了)

生產者/消費者輸出結果

Work: String: 0
Work: String: 1
Work: String: 2
Work: String: 3
Work: String: 4
Work: String: 5
Work: String: 6
Work: String: 7
Work: String: 8
Work: String: 9
Work: String: 10

場景二: 實現隊列FIFO(先進先出),LIFO(先進后出)

 //先進先出(FIFO)
 BlockingCollection<int> bc = new(new ConcurrentQueue<int>());
 bc.Add(1);
 bc.Add(2);
 bc.CompleteAdding();

 //先進后出(LIFO)
 BlockingCollection<int> bc2 = new(new ConcurrentStack<int>());
 bc2.Add(1);
 bc2.Add(2);
 bc2.CompleteAdding();

 bc.Take().Dump("bc1:");
 bc2.Take().Dump("bc2:");

隊列輸出結果

bc :1 
bc2: 2

這個簡單的案例是想介紹一下其實:BlockingCollection也可以實現隊列的功能

讀到這里,這篇“C#中神器類BlockingCollection怎么使用”文章已經介紹完畢,想要掌握這篇文章的知識點還需要大家自己動手實踐使用過才能領會,如果想了解更多相關內容的文章,歡迎關注億速云行業資訊頻道。

向AI問一下細節

免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。

AI

喀喇| 兴山县| 新巴尔虎右旗| 商南县| 大关县| 边坝县| 乐至县| 南川市| 客服| 三门峡市| 阿拉善右旗| 大竹县| 车致| 灵丘县| 许昌市| 永川市| 江华| 九龙城区| 四子王旗| 滁州市| 抚宁县| 乌兰察布市| 桑植县| 江陵县| 临朐县| 桂平市| 邻水| 句容市| 松原市| 阿鲁科尔沁旗| 原平市| 关岭| 南雄市| 桦南县| 中西区| 恩平市| 肃北| 依安县| 桂东县| 饶阳县| 安化县|