using System;
using System.Threading;
namespace _012_線程
{
  class Program
  {
    static void Main(string[] args) //在mian中線程是執(zhí)行一個(gè)線程里面的語句的執(zhí)行，是從上到下的
    {
      //通過委托 開啟一個(gè)線程
      //==============可用泛型傳參數(shù)（無返回值）==============
      Action threaA = ThreadTestA;
      threaA.BeginInvoke(null,null); //開啟一個(gè)新的線程去執(zhí)行，threaA所引用的方法
      Action<int> threaB = ThreadTestB;
      threaB.BeginInvoke(111,null, null);
      //可以認(rèn)為線程是同時(shí)執(zhí)行的 （異步執(zhí)行）
      Console.WriteLine("異步執(zhí)行");
      //================帶返回值的形式====================
      //第一種方式 檢測(cè)線程結(jié)束  ----- IsCompleted線程是否行完畢
      //Func<int, int> threaC = ThreadTestC;
      ////接收異步線程返回值
      //IAsyncResult returnResult = threaC.BeginInvoke(111, null, null);
      //while (!res.IsCompleted)
      //{
      //  Console.Write(".");
      //  Thread.Sleep(10); //控制子線程的檢測(cè)頻率,（每10ms檢測(cè)一次）
      //}
      ////取得異步線程返回值
      //int result = threaC.EndInvoke(res);
      //Console.WriteLine("IsCompleted方式檢測(cè)：" + result);
      //第二種方式 檢測(cè)線程結(jié)束  -----  1000ms沒結(jié)束就返回false，反之
      Func<int, int> threaC = ThreadTestC;
      //接收異步線程返回值
      IAsyncResult returnResult = threaC.BeginInvoke(111, null, null);
      bool isEnd = returnResult.AsyncWaitHandle.WaitOne(1000);
      int result = 0;
      if (isEnd)
      {
        result = threaC.EndInvoke(returnResult);
      }
      Console.WriteLine("EndInvoke()方式檢測(cè)：" + isEnd +" "+ result);
      //第三種方式  檢測(cè)線程結(jié)束  ----- 通過回調(diào)，檢測(cè)線程結(jié)束
      Func<int,string, string> threaD = ThreadTestD;
      //倒數(shù)第二個(gè)參數(shù)，表示委托類型的參數(shù)，（回調(diào)函數(shù)）當(dāng)線程結(jié)束的時(shí)候會(huì)調(diào)用這個(gè)委托指向的方法
      //最后一個(gè)參數(shù)，用來給回調(diào)函數(shù)傳遞數(shù)據(jù)
      IAsyncResult asy = threaD.BeginInvoke(111,"Czhenya", OnCallKey, threaD);
      //改為Lamdba表達(dá)式
      threaD.BeginInvoke(111, "Czhenya",(ar)=>{
        string res = threaD.EndInvoke(ar);
        Console.WriteLine("在Lamdba表達(dá)式中取得："+res);
      },null);
      Console.ReadKey();
    }
    static void OnCallKey(IAsyncResult ar)
    {
      Func<int, string, string> thread = ar.AsyncState as Func<int, string, string>;
      string res = thread.EndInvoke(ar);
      Console.WriteLine("在回調(diào)函數(shù)中取到的結(jié)果 :"+res);
    }
    /// <summary>
    /// 一般是比較耗時(shí)的操作方法
    /// </summary>
    static void ThreadTestA()
    {
      Console.WriteLine("ThreaTestA");
    }
    static void ThreadTestB(int num)
    {
      Console.WriteLine("ThreaTestB "+num);
    }
    static int ThreadTestC(int num)
    {
      Console.WriteLine("ThreaTestC");
      Thread.Sleep(100); //讓當(dāng)前線程休眠（暫停線程（參數(shù)單位：ms））
      return num;
    }
    static string ThreadTestD(int num,string str)
    {
      Console.WriteLine("ThreaTestD");
      return num +" "+ str;
    }
  }
}