文章出處
文章列表
接上文 多線程編程學習筆記-基礎（一）
接上文 多線程編程學習筆記-基礎（二）
九、向線程傳遞參數
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.結果如下圖。
在程序中定義了兩個處理異常的方法，一個對異常進行了處理，另一個沒有對異常進行處理。最后如圖。程序崩潰了。
文章列表
全站熱搜
留言列表
