項目開發中應用併發的一二事

来源:https://www.cnblogs.com/zhiyong-ITNote/archive/2018/01/13/8279140.html

在多線程環境下,使用BlockingCollection以及ConcurrentQueue來消費生產者生產的資源,這是我自己寫的多生產者多消費者的作法,其實也是基於單個task下的阻塞隊列的IsComplete來識別的。 使用阻塞隊列更簡單但是內部的消費者線程比較適合使用單獨的線程不適合使用線程池, ...

在多線程環境下,使用BlockingCollection以及ConcurrentQueue來消費生產者生產的資源,這是我自己寫的多生產者多消費者的作法,其實也是基於單個task下的阻塞隊列的IsComplete來識別的。

使用阻塞隊列更簡單但是內部的消費者線程比較適合使用單獨的線程不適合使用線程池,而且阻塞隊列為空時會阻塞消費者線程,當然阻塞線程池內的線程也沒什麼影響只是不推薦這麼做,而且阻塞的隊列的性能也沒有ConcurrentQueue的性能高。

我在項目中遇到多生產者多消費者問題,多生產者沒有問題,但是如何在多線程下消費生產者的資源,這就是比較麻煩了,不能僅僅通過判斷數量來做,網上也找了一些資源,但是也都是給了個demo,還不全,自己想了個方法,暫時解決了,回頭在研究下別人封裝的基於Thread的作法。其實是在<<.NET 中的阻塞隊列BlockingCollection的正確打開方式>>基礎上做的,也沒有什麼,但是這是個好思路。後續嘗試自己封裝線程標誌來做,不依靠FCL的阻塞隊列。code如下:

ConcurrentDictionary<string, string> dic1 = new ConcurrentDictionary<string, string>();
            ConcurrentDictionary<string, string> dic2 = new ConcurrentDictionary<string, string>();
            ConcurrentQueue<string> queue = new ConcurrentQueue<string>();
            BlockingCollection<string> blockingCollection = new BlockingCollection<string>();

            var t = new Task[50];
            Console.WriteLine("生產者開始寫入數據.............\r\n");
            
            for(int i=0; i<=49; i++)
            {
                t[i] = Task.Factory.StartNew((param) =>
                {
                    Console.WriteLine("生產者中 *** 阻塞隊列輸入: {0}", param.ToString());
                    blockingCollection.Add(param.ToString());
                    Console.WriteLine("生產者中 *** 阻塞隊列的數量是: {0}", blockingCollection.Count);

                    Console.WriteLine("生產者中 *** 字典dic1輸入: {0}", param.ToString());
                    dic1.TryAdd(param.ToString(), param.ToString());
                    Console.WriteLine("生產者中 *** 字典dic1的數量是: {0}", dic1.Count);

                    Console.WriteLine("生產者中 *** 字典dic2輸入: {0}", param.ToString());
                    dic2.TryAdd(param.ToString(), param.ToString());
                    Console.WriteLine("生產者中 *** 字典dic2的數量是: {0}", dic2.Count);

                    Console.WriteLine("生產者中 *** 隊列輸入: {0}", param.ToString());
                    queue.Enqueue(param.ToString());
                    Console.WriteLine("生產者中 *** 隊列的數量: {0}", queue.Count);
                }, i);
            }
            
            //Thread.Sleep(500);
            Console.WriteLine("\r\n消費者開始讀入數據.............\r\n");

            while (!blockingCollection.IsCompleted)
            {
                Task tt = Task.Factory.StartNew(() =>
                {
                    foreach (var b in blockingCollection.GetConsumingEnumerable())
                    {
                        Console.WriteLine("消費者中 *** 字典dic1的數量是: {0}", dic1.Count);
                        Console.WriteLine("消費者中 *** 字典dic2的數量是: {0}", dic2.Count);

                        Console.WriteLine("消費者中 *** 阻塞隊列的數量是: {0}", blockingCollection.Count);

                        string value1 = "";
                        string value2 = "";
                        dic1.TryGetValue(b, out value1);
                        dic2.TryGetValue(b, out value2);

                        Console.WriteLine("消費者中 *** 字典dic1的鍵值{0}的value值是: {1}", b, value1);
                        Console.WriteLine("消費者中 *** 字典dic1的鍵值{0}的value值是: {1}", b, value2);
                        Console.WriteLine("消費者中 *** 隊列的數量是: {0}", queue.Count);
                        Console.WriteLine("消費者中 *** 字典的數量是: {0}", dic1.Count);

                        if (queue.Count == 50)
                        {
                            blockingCollection.CompleteAdding();
                        }
                    }
                });
            }

            Console.WriteLine("是否完成添加: {0}", blockingCollection.IsCompleted);

參考:

.Net中的並行編程-7.基於BlockingCollection實現高性能非同步隊列


您的分享是我們最大的動力!

更多相關文章
一周排行
  • 一、課程介紹 曾經有一位不知名的講師說過這麼一句名言: 一門RPC技術不會,那麼千萬萬門RPC技術將都不會!在今天移動互聯網的時代,作為攻城師的我們,誰不想著只寫一套API就可以讓我們的Web, Android APP, IOS APP, iPad APP, Hybired APP, H5 Web共 ...
  • MVC也好,WebAPI也好,據我所知,有部分人是因為複雜的路由,而不想去學的。曾經見過一位程式猿,在他MVC程式中,一切皆路由,url中是完全拒絕"?"和“&”。對此,我也不好說什麼,搞不好是個人風格。路由雖然重要,但其實也只是實現MVC的一種手段,並非你用的路由越多,你的url完全不使用參數,你 ...
  • 基於Ubuntu安裝redis, 我找的一個很好的網站: https://www.digitalocean.com/community/tutorials/how-to-install-and-configure-redis-on-ubuntu-16-04設置redis密碼登錄, 編輯redis.c ...
  • 原文鏈接 一.Has方法: 二.With方法: ...
  • 本文的概念性內容來自深入淺出設計模式一書 項目需求 這是一個糖果機的需求圖. 它有四種狀態, 分別是圖中的四個圓圈: No Quarter: 無硬幣 Has Quater 有硬幣 Gumball Sold 糖果賣出 Out of Gumball 沒有糖果了 這個圖很像一個狀態圖. 每個圓圈就是一個狀 ...
  • 最近有個統計分佈的需求,需要按統計本周,上周,本月,上月,本季度,上季度,本年度,上年度等時間統計分佈趨勢,所以這裡就涉及到計算周,月,季度,年度等的起止時間了,下麵總結一下C#中關於根據當前時間獲取周,月,季度,年度等時間段的起止時間的方法,廢話不多說,直接貼代碼,如果你覺得有用,請多多推薦。 ...
  • 本文是一篇介紹net同步非同步的文章,是為張四火同學原創的。請張四活同學及廣大讀者指出,文章不通順的地方。後續應當還有兩篇文章敬請期待 ...
  • 在WPF里用MediaElement控制項,實現一個迴圈播放單一視頻的程式,同時可以控制視頻的播放、暫停、停止。 一種方式,使用MediaElement.MediaEnded事件,在視頻播放結束後,自動重新播放; 另一種方式,使用WPF定時器,在定時器事件里寫入視頻播放代碼。 後者優點是可以控制迴圈時 ...
  • 最近因為公司業務需要,又有機會擼winform了,這次的需求是因為公司有項目申報的這塊業務,項目申報前期需要關註政府發佈的相關動態信息,政府部門網站過多,人工需要一個一個網站去瀏覽和查閱,有時候還會遺漏掉,因此呢,我們打算用爬蟲+移動端web來做,我呢主要負責爬蟲和web Api。 爬蟲篇 爬蟲主要 ...
  • AspNetCoreApi 跨域處理 如果咱們有處理過MV5 跨域問題這個問題也不大。 (1)為什麼會出現跨域問題: 瀏覽器安全限制了前端腳本跨站點的訪問資源,所以在調用WebApi 介面時不能成功訪問資源,原因“同源策略”的存在: 同源指以下幾點相同 (1) IP地址/功能變數名稱 (2) 埠號 (3) ...