多線程編程學習筆記-基礎（三）

来源:http://www.cnblogs.com/chillsrc/archive/2017/10/25/7728578.html
-Advertisement-
Play Games

接上文 多線程編程學習筆記-基礎（一） 接上文 多線程編程學習筆記-基礎（二） 九、向線程傳遞參數 1.代碼如下。 2.結果如下圖。 線程1，我們通過實例化對象來進行參數傳遞。 線程2，我們使用Ｔhread.Start()來傳遞參數，不過此方法只接收單個參數，而且是對象類型。 線程3，我們使用lam ...


接上文 多線程編程學習筆記-基礎（一）

接上文 多線程編程學習筆記-基礎（二）

九、向線程傳遞參數

 1.代碼如下。

 

using System;

using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading; //引入線程
using System.Diagnostics;
 

namespace ThreadConsoleApp
{

    class Program
    {
        static void Main(string[] args)
        {

            Console.WriteLine("開始，給線程傳參數");          

            var fore = new ThreadBackground(10);   

            Thread t = new Thread(fore.CountNumber);
            t.Name = "線程1";         

            //啟動線程

            t.Start();
            t.Join();
            Console.WriteLine("----------------------------"); 

            var t2 = new Thread(Count);
            t2.Name = "線程2";
            t2.Start(8);
            t2.Join();
            Console.WriteLine("----------------------------"); 

            var t3 = new Thread(()=>CountNumber(12));
            t3.Name = "線程3";
            t3.Start();
            t3.Join();
            Console.WriteLine("----------------------------");

 

            int i = 10;
            var t4 = new Thread(() => PrintNumber(i));
            t4.Name = "線程4";
            i = 20;
            var t5 = new Thread(() => PrintNumber(i));
            t5.Name = "線程5";
            t4.Start();
            t5.Start();
            Console.Read();
        }

        static void CountNumber(int cnt)
        {
            for (int i = 0; i < cnt; i++)
            {

                Thread.Sleep(500);
                Console.WriteLine(string.Format(" {0}    列印 {1,11} 數字", Thread.CurrentThread.Name, i.ToString("N0")));

            }

        }

        static void Count(object cnt)
        {
            CountNumber((int)cnt);
        }
        static void PrintNumber(int num)
        {        

            Console.WriteLine(string.Format(" {0} 列印 {1,11} 數字", Thread.CurrentThread.Name, num.ToString("N0")));         

        } 
    }
}

 

 2.結果如下圖。

 

線程1，我們通過實例化對象來進行參數傳遞。

線程2，我們使用Ｔhread.Start()來傳遞參數，不過此方法只接收單個參數，而且是對象類型。

線程3，我們使用lambda表達式進行參數傳遞，lambda表達式定義了一個不屬於任何類的方法，同時該方法調用了我們實際要執行的方法，同時傳遞參數給線程。

線程4與線程5，則是顯示了使用lambda表達式進行參數傳遞的一個問題，即當多個lambda表達式共用一個變數時，它們會共用這個變數的值。如圖中線程4與線程5所顯示，沒有列印10，只列印了20。

 

十、使用lock鎖定操作

 1.代碼如下

 

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading; //引入線程
using System.Diagnostics;
 

namespace ThreadConsoleApp
{
    class Program
    {

        static void Main(string[] args)
        {
            Console.WriteLine("開始，給線程加鎖");           

            var c = new Counter();           

            Thread t = new Thread(()=>Count(c));
            var t3 = new Thread(() => Count(c));

             var t2 = new Thread(() => Count(c));
            t.Name = "線程1";         

            //啟動線程
            t.Start();
         

            t2.Name = "線程2";
            t2.Start();     
 
            t3.Name = "線程3";
            t3.Start();
            t.Join();
            t2.Join();     
            t3.Join();
            Console.WriteLine(string.Format("沒有加鎖的多線程總計：{0}",c.Count));
            Console.WriteLine("----------------------------");


            var c1 = new CounterLock();
            var t4 = new Thread(() => Count(c1));
            t4.Name = "線程4";
           

            var t5 = new Thread(() => Count(c1));
            t5.Name = "線程5";
            var t6 = new Thread(() => Count(c1));
            t6.Name = "線程6";

            t4.Start();
            t5.Start();
            t6.Start();
            t4.Join();
            t5.Join();
            t6.Join();
            Console.WriteLine(string.Format("加鎖的多線程總計：{0}", c1.Count));
            Console.Read();
        }      

        static void Count(CountBase cnt)
        {
            for (int i = 0; i < 100000; i++)
            {
                cnt.Incerement();
                cnt.Dncerement();

            }
        }
     }

    abstract class CountBase
    {
         public abstract void  Incerement();
        public abstract void Dncerement();
    }

    class Counter : CountBase
    {
        public int Count { get; private set; }
        public override void Dncerement()
        {
            Count--;
        }

        public override void Incerement()
        {

            Count++;
        }
    }

    class CounterLock : CountBase
    {
        private readonly object objSync = new object();
        public int Count { get; private set; }
        public override void Dncerement()
        {
            lock (objSync)
            {
                Count--;
            }       
        }

        public override void Incerement()
        {
            lock (objSync)
            {
                Count++;
            }
        }
    }

}

2. 結果如下圖

 

      主線程首先創建了一個 Counter的實例對象，這個類定義了一個可以增，可以 減的簡單計數器。然後我們創建了三個線程，這三個線程共用一個Counter對象。由於沒有對共用變數的鎖定，所以在一個周期內，對共用變數的改變，在上個線程沒結束之前，當前線程又對共用變數進行了操作，我們會得到不同的計數值，如上圖所示。為了防止這種情況的發生，所以我們要對共用變數進行加鎖。使用lock關鍵字鎖定對象，這樣在一個線程操作完成之前，其他線程都不能對共用變數進行操作。

 

十一、Moniter對資源的鎖定

 1.代碼如下

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading; //引入線程
using System.Diagnostics; 

namespace ThreadConsoleApp
{   
 class Program
    {
        static void Main(string[] args)
        {

            Console.WriteLine("開始，線程死鎖");          

            var lock1 = new object();
            var lock2 = new object();
           

            Thread t = new Thread(()=> DeadLock(lock1,lock2));
            t.Name = "線程1";       

            //啟動線程

            t.Start();
            lock (lock2)
            {
                Thread.Sleep(2000); 

                if (Monitor.TryEnter(lock1,TimeSpan.FromSeconds(5)))

                {
                    Console.WriteLine("在規定時間內，請求資源");

                }
                else

                {
                    Console.WriteLine("超時，無法獲取資源");

                }
            }

            new Thread(() => DeadLock(lock1, lock2)).Start();
             Console.WriteLine("-----------------------------");

            lock (lock2)
            {

                Thread.Sleep(1000);
                Console.WriteLine(string.Format("死鎖線程"));

               lock(lock1)
                {
                    Console.WriteLine("請求資源成功");

                }          
           }

            Console.Read();
        }
      

        /// <summary>
        /// 死鎖方法
        /// </summary>
        /// <param name="objLock1"></param>
        /// <param name="objLock2"></param>
        static void DeadLock(object objLock1,object objLock2)
        {
            lock (objLock1)
            {
                Thread.Sleep(2000);
                lock (objLock2)
                {
                    Console.WriteLine("死鎖");
                }
            }
        }
    }
}

2.結果如下圖

 

 先看deadlock方法，這個方法先鎖定lock1對象，然後等待2秒之後，鎖定了lock2對象。然後在子線程中啟動了這個方法。

主線程中先鎖定了lock2對象，然後等待獲取lock1對象。由於子線程鎖定了lock1對象，等待lock2對象。所以造成了死鎖。

 

十二、多線程的異常處理

 1.代碼如下

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading; //引入線程
using System.Diagnostics;
 
namespace ThreadConsoleApp
{
    class Program
    {
        static void Main(string[] args)
        {

            Console.WriteLine("開始，異常處理");          
            Thread t = new Thread(FaultyThread);
            t.Name = "線程1";        

            //啟動線程
            t.Start();
            t.Join();
            try
            {
                t = new Thread(ExpectThread);
                t.Start();
            }

            catch (Exception ex)
            {
                Console.WriteLine("異常信息：" + ex.Message);
            }
            Console.Read();
        }    

        static void ExpectThread()
        {
            Console.WriteLine(string.Format("異常處理"));
            Thread.Sleep(2000);
            throw new Exception("拋出異常");
        }
        static void FaultyThread()
        {
            try
            {
                Console.WriteLine(string.Format("異常處理2"));
                Thread.Sleep(1000);
                throw new Exception("拋出異常2");
            }

            catch (Exception ex)
            {
                Console.WriteLine(string.Format("異常處理2:{0}",ex.Message));
            }        

        }
    }
}

 

 2.結果如下圖。

 

 在程式中定義了兩個處理異常的方法，一個對異常進行了處理，另一個沒有對異常進行處理。最後如圖。程式崩潰了。


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

-Advertisement-
Play Games
更多相關文章
  • C#中的泛型和泛型集合
    一、什麼是泛型？ 泛型是C#語言和公共語言運行庫（CLR）中的一個新功能，它將類型參數的概念引入.NET Framework。類型參數使得設計某些類和方法成為可能，例如，通過使用泛型類型參數T，可以大大簡化類型之間的強制轉換或裝箱操作的過程（下一篇將說明如何解決裝箱、拆箱問題）。說白了，泛型就是通過 ...
  • 先記下這些小毛病，後面在慢慢回味-第一篇
    一.連接字元串的兩種寫法 sqlserver連接字元串寫法（MSDN推薦的） Datasource=伺服器ip Initial catalog=資料庫名稱 User Id=用戶名 Password=密碼 或者 Server=伺服器ip Database=資料庫名稱 User Id=用戶名 Passw ...
  • 還有好多要掌握的
    從某網站上摘抄過來的，覺得整理的挺詳細，方便自己知道怎麼去學習 ...
  • C# .NET知識體系圖
    C# .NET知識體系圖 一.C#基礎 二.資料庫 三.WEB技術 四.ASP.NET WebForm 五.ASP.NET MVC 六.ASP.NET WebAPI 七.WebService技術 八.Remoting技術 九.WCF通信技術(替代Remoting技術 十.常用框架 十一.ASP.NE ...
  • Newtonsoft.Json 版本衝突時解決方案
    如果同一項目中不同第三方類庫分別使用了不同版本的Newtonsoft.Json的情況下，可以在主項目配置文件中添加以下節點，將0.0.0.0-11.0.0.0此區間的Newtonsoft.Json使用全部強制指向到9.0.0.0版本。 如果同一項目中不同第三方類庫分別使用了不同版本的Newtonso ...
  • C# 讀寫鎖
    讀寫鎖 /// /// 提供非同步獨占和併發執行支持 /// public sealed class AsyncReaderWriter { /// /// 在當前實例中保護所有共用狀態的鎖 /// private readonly object _lock = new object(); /// / ...
  • 雜七雜八的問題及解決方案
    剛開博，實在無從下手，就先堆一篇，當做個筆記，見笑了。 雖然很早就註冊了博客園賬號，但大多進來只是隨便逛逛，或在開發過程中遇到問題的時候進來找找答案。 作為圈子裡少而不稀的女程式員，從事Web開發，接觸的一直是MVC。說真的，我對敲代碼並沒啥興趣，只是當年被調劑到了軟體工程專業，一切順其自然便走上了 ...
  • 在MVC中使用rdlc格式的報表
    前言 近期，在公司做的項目中做到報表模塊需要使用rdlc格式的報表，這個報表需要使用WebForm來載入，但是現在用ASP.NET做項目基本上都是MVC。由於以前沒有使用過，因此記錄下來，供以後查閱。 下麵做個簡單的Demo，使用的工具是VS2012+SQL Server2012。 一、準備資料庫 ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發（一）：使用.NET MAUI開發第一個安卓APP
    移動開發（一）：使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說，近來想嘗試開發一款安卓APP，考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP，畢竟是使用Visual Studio開發工具，使用起來也比較的順手，結合微軟官方的教程進行了安卓 ...
  • wpf ToggleButton選中效果和一個登錄界面
    前言 QuestPDF 是一個開源 .NET 庫，用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫，它徹底改變了我們生成 PDF 文檔的方 ...
  • 彈幕樹洞項目功能新增篇
    項目地址 項目後端地址： https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址： ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址： http://tree ...
  • 第27篇 sqlserver2022詳細安裝步驟
    話不多說，直接開乾 一.下載 1.官方鏈接下載： https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe，運行開始下載SQL server； 二. ...
  • .NET 開源高性能 MQTT 類庫
    前言 隨著物聯網（IoT）技術的迅猛發展，MQTT（消息隊列遙測傳輸）協議憑藉其輕量級和高效性，已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫，為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog文檔翻譯系列（六） - 可用的接收器、增強器、格式化輸出
    Serilog支持多種接收器用於日誌存儲，增強器用於添加屬性，LogContext管理動態屬性，支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項，適用於不同需求。 ...
  • 警惕 Visual Studio 屬性求值副作用導致邏輯不符合預期
    目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據，爬取信息時需要模擬瀏覽器行為，否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下： 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • [使用目前最新版]HybridCLR6.9.0+YooAsset2.2.4實現純C# Unity熱更新方案 (一)
    1.前言 什麼是熱更新 游戲或者軟體更新時，無需重新下載客戶端進行安裝，而是在應用程式啟動的情況下，在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR，Xlua，ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles，Addressable， ...
  • 在 ASP.NET Core Web API 中使用操作篩選器統一處理通用操作
    本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺，其實像阿裡雲，騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後，它會送 ...
  • 第28篇 如何.net中實現高效可靠數據同步api
    通過以下方式可以高效，並保證數據同步的可靠性 1.API設計 使用RESTful設計，確保API端點明確，並使用適當的HTTP方法（如POST用於創建，PUT用於更新）。 設計清晰的請求和響應模型，以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類