前幾天碰到一個(gè)線程的順序執(zhí)行的問題，就是一個(gè)異步線程往A接口發(fā)送一個(gè)數(shù)據(jù)請(qǐng)求。另外一個(gè)異步線程往B接口發(fā)送一個(gè)數(shù)據(jù)請(qǐng)求，當(dāng)A和B都執(zhí)行成功了，再往C接口發(fā)送一個(gè)請(qǐng)求。說真的，一直做BS項(xiàng)目，對(duì)線程了解，還真不多。就知道AutoResetEvent這個(gè)東西和線程有關(guān)，用于處理線程切換之類，于是決定用AutoResetEvent來處理上面的問題。

于是網(wǎng)上查找相關(guān)資料：

原來，AutoResetEvent在.Net多線程編程中經(jīng)常用到。當(dāng)某個(gè)線程調(diào)用WaitOne方法后，信號(hào)處于發(fā)送狀態(tài),該線程會(huì)得到信號(hào), 程序就會(huì)繼續(xù)向下執(zhí)行，否則就等待。而且 AutoResetEvent.WaitOne()每次只允許一個(gè)線程進(jìn)入，當(dāng)某個(gè)線程得到信號(hào)后，AutoResetEvent會(huì)自動(dòng)又將信號(hào)置為不發(fā)送狀態(tài)，其他調(diào)用WaitOne的線程只有繼續(xù)等待.也就是說,AutoResetEvent一次只喚醒一個(gè)線程，其他線程還是堵塞。

簡介

AutoResetEvent(bool initialState)：構(gòu)造函數(shù)，用一個(gè)指示是否將初始狀態(tài)設(shè)置為終止的布爾值初始化該類的新實(shí)例。
    false：無信號(hào)，子線程的WaitOne方法不會(huì)被自動(dòng)調(diào)用
    true：有信號(hào)，子線程的WaitOne方法會(huì)被自動(dòng)調(diào)用
　Reset ()：將事件狀態(tài)設(shè)置為非終止?fàn)顟B(tài)，導(dǎo)致線程阻止；如果該操作成功，則返回true；否則，返回false。
　Set ()：將事件狀態(tài)設(shè)置為終止?fàn)顟B(tài)，允許一個(gè)或多個(gè)等待線程繼續(xù)；如果該操作成功，則返回true；否則，返回false。
　WaitOne()： 阻止當(dāng)前線程，直到收到信號(hào)。
　WaitOne(TimeSpan, Boolean) ：阻止當(dāng)前線程，直到當(dāng)前實(shí)例收到信號(hào)，使用 TimeSpan 度量時(shí)間間隔并指定是否在等待之前退出同步域。   
    WaitAll()：等待全部信號(hào)。 

實(shí)現(xiàn)

 class Program
 {

  static void Main()
  {
   Request req = new Request();

   //這個(gè)人去干三件大事 
   Thread GetCarThread = new Thread(new ThreadStart(req.InterfaceA));
   GetCarThread.Start();

   Thread GetHouseThead = new Thread(new ThreadStart(req.InterfaceB));
   GetHouseThead.Start();

   //等待三件事都干成的喜訊通知信息 
   AutoResetEvent.WaitAll(req.autoEvents);

   //這個(gè)人就開心了。 
   req.InterfaceC();

   System.Console.ReadKey();
  }
 }

 public class Request
 {
  //建立事件數(shù)組 
  public AutoResetEvent[] autoEvents = null;

  public Request()
  {
   autoEvents = new AutoResetEvent[]
   {
    new AutoResetEvent(false),
    new AutoResetEvent(false)
   };
  }

  public void InterfaceA()
  {
   System.Console.WriteLine("請(qǐng)求A接口");

   Thread.Sleep(1000*2);

   autoEvents[0].Set();

   System.Console.WriteLine("A接口完成");
  }

  public void InterfaceB()
  {
   System.Console.WriteLine("請(qǐng)求B接口");

   Thread.Sleep(1000 * 1);

   autoEvents[1].Set();

   System.Console.WriteLine("B接口完成");
  }

  public void InterfaceC()
  {
   System.Console.WriteLine("兩個(gè)接口都已經(jīng)請(qǐng)求完，正在處理C");
  }
 }

注意，WaitOne 或是WaitAll 最好都加上超時(shí)時(shí)間。否則沒有收到信號(hào)，線程一直會(huì)阻塞。 

后話

這個(gè)只是上面的場(chǎng)景的一個(gè)簡化，主要是用來解決剛剛我說的那個(gè)場(chǎng)景的問題。
以上是自己對(duì)AutoResetEvent的使用總結(jié)。不足之處請(qǐng)各位指點(diǎn)一二。

以上就是本文的全部內(nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。

最新評(píng)論