C# 線程間互相通信


  C#線程間互相通信主要用到兩個類:AutoResetEvent和ManualResetEvent.
  一、AutoResetEvent
  AutoResetEvent 允許線程通過發信號互相通信,線程通過調用 AutoResetEvent 上的 WaitOne 來等待信號。 如果 AutoResetEvent 為非終止狀態,則線程會被阻止,並等待當前控制資源的線程通過調用 Set 來通知資源可用。
  下面我用吃快餐的例子來說明這個問題,吃快餐的時候都會排隊付款,收銀員發送收款通知,客戶依次付錢,代碼如下:
  復制代碼
  1 class Program
  2 {
  3 //若要將初始狀態設置為終止,則為 true;若要將初始狀態設置為非終止,則為 false
  4 static AutoResetEvent autoResetEvent = new AutoResetEvent(false);
  5
  6 static void Main(string[] args)
  7 {
  8 Thread t1 = new Thread(() =>
  9 {
  10 Console.WriteLine("客戶1在排隊等待付錢…");
  11
  12 //客戶1調用AutoResetEvent上的WaitOne來等待付錢通知
  13 autoResetEvent.WaitOne();
  14 Console.WriteLine("通知來了,客戶1付錢");
  15 });
  16 t1.IsBackground = true;
  17 t1.Start();
  18
  19 Pay();//發送通知
  20 Console.ReadKey();
  21 }
  22
  23 static void Pay()
  24 {
  25 string tip = Console.ReadLine();
  26 if (tip == "next")
  27 {
  28 autoResetEvent.Set();//收銀員發送付錢通知,通過調用Set來通知客戶付錢
  29 }
  30 }
  31 }
  復制代碼
  運行在屏幕中打印:
  客戶1在排隊等待付錢…
  等收銀員說"next"的時候,向客戶1發送付錢通知(autoResetEvent.Set()),屏幕打印:
  客戶1在排隊等待付錢…
  next
  通知來了,客戶1付錢!
  AutoResetEvent類一次只能通知一個等待的線程,且通知一次過后會立即將AutoResetEvent對象的狀態置為false,也就是如果有兩個客戶都在等待收銀員通知,AutoResetEvent對象的set方法只能通知到第一個客戶,代碼和效果如下:
  復制代碼
  1 class Program
  2 {
  3 //若要將初始狀態設置為終止,則為 true;若要將初始狀態設置為非終止,則為 false.
  4 static AutoResetEvent autoResetEvent = new AutoResetEvent(false);
  5
  6 static void Main(string[] args)
  7 {
  8 Thread t1 = new Thread(() =>
  9 {
  10 Console.WriteLine("客戶1在排隊等待付錢…");
  11
  12 //客戶1調用AutoResetEvent上的WaitOne來等待付錢通知
  13 autoResetEvent.WaitOne();
  14 Console.WriteLine("通知來了,客戶1付錢");
  15 });
  16 t1.IsBackground = true;
  17 t1.Start();
  18
  19 Thread t2 = new Thread(() =>
  20 {
  21 Console.WriteLine("客戶2在排隊等待付錢…");
  22
  23 //客戶2調用AutoResetEvent上的WaitOne來等待付錢通知
  24 autoResetEvent.WaitOne();
  25 Console.WriteLine("通知來了,客戶2付錢!");
  26 });
  27 t2.IsBackground = true;
  28 t2.Start();
  29
  30 Pay();//發送通知
  31
  32 Console.ReadKey();
  33 }
  34
  35 static void Pay()
  36 {
  37 string tip = Console.ReadLine();
  38 if (tip == "next")
  39 {
  40 autoResetEvent.Set();//收銀員發送付錢通知,通過調用Set來通知客戶付錢
  41 }
  42 }
  43 }
  復制代碼
  運行后屏幕打印:
  客戶1在排隊等待付錢…
  客戶1在排隊等待付錢…
  next
  通知來了,客戶1付錢!
  這就說明在通知完客戶1后,autoResetEvent 的狀態又被置為了false,這時如果要通知到客戶2,就需要在通知完客戶1后,再執行一次通知,在線程1中加上一行代碼,如下:
  復制代碼act答案 www.yzyxedu.com
  1 Thread t1 = new Thread(() =>
  2 {
  3 Console.WriteLine("客戶1在排隊等待付錢…");
  4
  5 //客戶1調用AutoResetEvent上的WaitOne來等待付錢通知
  6 autoResetEvent.WaitOne();
  7 Console.WriteLine("通知來了,客戶1付錢");
  8
  9 autoResetEvent.Set();//讓其再通知下個客戶
  10 });
  復制代碼
  運行后屏幕打印:
  客戶1在排隊等待付錢…
  客戶1在排隊等待付錢…
  next
  通知來了,客戶1付錢!
  通知來了,客戶2付錢!
  這也就說明每調用一次Set,只有一個線程會解除等待,換句話說,有多少個線程就要調用多少次Set,線程才會全部繼續。
  二、ManualResetEvent
  在AutoResetEvent中,如果要通知兩個線程,則Set方法要被執行兩次,也以快餐店的例子做了舉例,但如果有一天客戶1中彩票了,要請部門的10個同事吃飯,也就是說只要Set一次,所有在等待的線程都會解除等待,相當於收銀員只收一次錢,10個人都可以通過收銀去吃飯,這時我們就要用到ManualResetEvent類,它的用法和AutoResetEvent基本一樣,區別就在於它是一量Set方法發出通知后,要再次阻塞的話就需要手動去修改,也就是調用Reset方法,代碼如下:
  復制代碼
  1 class Program
  2 {
  3 //若要將初始狀態設置為終止,則為 true;若要將初始狀態設置為非終止,則為 false.
  4 static ManualResetEvent manualResetEvent = new ManualResetEvent(false);
  5
  6 static void Main(string[] args)
  7 {
  8 Thread t1 = new Thread(() =>
  9 {
  10 Console.WriteLine("客戶1在排隊等待付錢…");
  11
  12 //客戶1調用manualResetEvent上的WaitOne來等待付錢通知
  13 manualResetEvent.WaitOne();
  14 Console.WriteLine("已經有人請客,客戶1不用付錢");
  15 });
  16 t1.IsBackground = true;
  17 t1.Start();
  18
  19 Thread t2 = new Thread(() =>
  20 {
  21 Console.WriteLine("客戶2在排隊等待付錢…");
  22
  23 //客戶2調用manualResetEvent上的WaitOne來等待付錢通知
  24 manualResetEvent.WaitOne();
  25 Console.WriteLine("已經有人請客,客戶2不用付錢!");
  26 });
  27 t2.IsBackground = true;
  28 t2.Start();
  29
  30 Pay();//發送通知
  31
  32 Console.ReadKey();
  33 }
  34
  35 static void Pay()
  36 {
  37 string tip = Console.ReadLine();
  38 if (tip == "next")
  39 {
  40 manualResetEvent.Set();//收銀員發送付錢通知,通過調用Set來通知客戶付錢
  41 }
  42 }
  43 }
  復制代碼
  運行后屏幕打印:
  客戶1在排隊等待付錢…
  客戶1在排隊等待付錢…
  next
  已經有人請客,客戶1不用付錢!
  已經有人請客,客戶2不用付錢!
  如果收銀員在發送通知后5秒就下班了,就不能再收錢了,這時就要把通知重置掉,讓沒接到通知的客戶繼續處於繼續等待,代碼如下:
  復制代碼
  1 class Program
  2 {
  3 //若要將初始狀態設置為終止,則為 true;若要將初始狀態設置為非終止,則為 false.
  4 static ManualResetEvent manualResetEvent = new ManualResetEvent(false);
  5
  6 static void Main(string[] args)
  7 {
  8 Thread t1 = new Thread(() =>
  9 {
  10 Console.WriteLine("客戶1在排隊等待付錢…");
  11
  12 //客戶1調用manualResetEvent上的WaitOne來等待付錢通知
  13 manualResetEvent.WaitOne();
  14 Console.WriteLine("已經有人請客,客戶1不用付錢");
  15 });
  16 t1.IsBackground = true;
  17 t1.Start();
  18
  19 Thread t2 = new Thread(() =>
  20 {
  21 Console.WriteLine("客戶2在排隊等待付錢…");
  22
  23 Thread.Sleep(8000);//客戶2發呆了8秒,這時收銀員已經下班,要繼續等待
  24 //客戶2調用manualResetEvent上的WaitOne來等待付錢通知
  25 manualResetEvent.WaitOne();
  26 Console.WriteLine("已經有人請客,客戶2不用付錢!");
  27 });
  28 t2.IsBackground = true;
  29 t2.Start();
  30
  31 Pay();//發送通知
  32
  33 Console.ReadKey();
  34 }
  35
  36 static void Pay()
  37 {
  38 string tip = Console.ReadLine();
  39 if (tip == "next")
  40 {
  41 manualResetEvent.Set();//收銀員發送付錢通知,通過調用Set來通知客戶付錢
  42
  43 Timer timer = new Timer(StopPay, null, 0, 5000);//5秒鍾后收銀員下班了,線程要重新等待了
  44 }
  45 }
  46
  47 static void StopPay(object s)
  48 {
  49 manualResetEvent.Reset();
  50 Console.WriteLine("收銀員下班, 后面的客戶要繼續等待");
  51 }
  52 }
  復制代碼
  運行后屏幕打印:
  客戶1在排隊等待付錢…
  客戶1在排隊等待付錢…
  next
  已經有人請客,客戶1不用付錢!
  收銀員下班,后面的客戶要繼續等待
  總結
  AutoResetEvent和ManualResetEvent的主要區別就在於:AutoResetEvent一次只能通知一個等待線程,通知后自動關閉; 而ManualResetEvent一次可通知很多個等待的線程,但要關閉需要調用Reset方法手動關閉托福答案 www.yztrans.com


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM