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

来源: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實現高性能非同步隊列


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

更多相關文章
一周排行
  • 在 XAML 應用的開發過程中,使用 MVVM 框架能夠極大地提高軟體的可測試性、可維護性。MVVM 的核心思想是關註點分離,使得業務邏輯從 View 中分離出來到 ViewModel 以及 Model 中,從邏輯上來講,這也是業務邏輯應該處的位置。 具體來說,藉助於數據綁定 (Data Bindi ...
  • 在使用Entity Framework時,若有多個排序,需要OrderBy (OrderByDescending)再ThenBy (ThenByDescending) 假設需要根據Name升序排序,再根據Id降序排序,則: 藉助System.Linq.Dynamic的方式 首先需要在項目中引用Sys ...
  • 【01】淺談Google Chrome瀏覽器(理論篇) 【02】淺談Google Chrome瀏覽器(操作篇)(上) 【03】淺談Google Chrome瀏覽器(操作篇)(下) 【04】淺談ASP.NET框架 【05】淺談ASP.NET MVC運行過程 【06】淺談ASP.NET MVC 控制器 ...
  • package com.swift; public class Bank_Customer_Test { public static void main(String[] args) { /* * 兩個客戶往一個銀行存錢,每人存三十次一次存一百。 模擬銀行存錢功能,時時銀行現金數。 */ Custo... ...
  • 在當前的Java記憶體模型下,線程可以把變數保存在本地記憶體(比如機器的寄存器)中,而不是直接在主存中進行讀寫。這就可能造成一個線程在主存中修改了一個變數的值,而另外一個線程還繼續使用它在寄存器中的變數值的拷貝,造成數據的不一致。 在當前的Java記憶體模型下,線程可以把變數保存在本地記憶體(比如機器的寄存 ...
  • 題目描述 HXY得到了一些卡片,這些卡片上標有數字0或5。現在她可以選擇其中一些卡片排成一列,使得排出的一列數字組成的數最大,且滿足被90整除這個條件。同時這個數不能含有前導0,即0不能作為這串數的首位。如果不能排出這樣的數,輸出“-1”。 輸入輸出格式 輸入格式: 第一行,卡片的個數n。 第二行, ...
  • Tomcat 是什麼 Tomcat 是由 Apache 開發的一個 Servlet 容器,實現了對 Servlet 和 JSP 的支持,並提供了作為Web伺服器的一些特有功能,如Tomcat管理和控制平臺、安全域管理和Tomcat閥等。 由於 Tomcat 本身也內含了一個 HTTP 伺服器,它也可 ...
  • 題目描述 某人寫了n封信和n個信封,如果所有的信都裝錯了信封。求所有信都裝錯信封共有多少種不同情況。 輸入輸出格式 輸入格式: 一個信封數n(n<=20) 輸出格式: 一個整數,代表有多少種情況。 輸入輸出樣例 輸入樣例#1: 複製 2 輸出樣例#1: 複製 1 輸入樣例#1: 複製 2 輸出樣例# ...
  • 上面只是做到讀取並寫入另一個文件,並沒有進行排序 下麵是排序的方法 ...
  • 百度UMeditor富文本編輯器java使用 1.介紹 UMeditor 是一款輕量級的富文本編輯器,比UEditor要小得多,是為滿足廣大門戶網站對於簡單發帖框,或者回覆框需求所定製的線上富文本編輯器 2.下載 官網地址:http://ueditor.baidu.com/website/umedi ...