快捷導(dǎo)航

一文搞懂c# await,async執(zhí)行流

更新時(shí)間：2020年06月11日 16:50:19 作者：一線(xiàn)碼農(nóng)

這篇文章主要介紹了c# await，async執(zhí)行流的相關(guān)知識(shí)，文章講解的非常細(xì)致，代碼幫助理解和學(xué)習(xí)，感興趣的朋友可以了解下

昨天有朋友在公眾號(hào)發(fā)消息說(shuō)看不懂a(chǎn)wait，async執(zhí)行流，其實(shí)看不懂太正常了，因?yàn)槟銢](méi)經(jīng)過(guò)社會(huì)的毒打，沒(méi)吃過(guò)牢飯就不知道自由有多重要，沒(méi)生過(guò)病就不知道健康有多重要，沒(méi)用過(guò)ContinueWith就不知道await,async有多重要，下面我舉兩個(gè)案例佐證一下？

一：案例一【嵌套下的異步】

寫(xiě)了這么多年的程序，相信大家都知道連接數(shù)據(jù)庫(kù)少不了這幾個(gè)對(duì)象，DbConnection，DbCommand，DbDataReader等等。。先來(lái)看看ContinueWith在連接數(shù)據(jù)庫(kù)時(shí)嵌套過(guò)深的尷尬。

1. NetFramework 4.0之前的寫(xiě)法

這個(gè)時(shí)期的代碼沒(méi)有什么好說(shuō)的，都是程式代碼，一擼到底，簡(jiǎn)潔明了。

 public static int SyncGetCount()
 {
  using (var connection = new MySqlConnection("server=xxx.xxx.xxx.xxx;userid=xxx;password=xxx;database=xxx;charset=utf8;port=3306;"))
  {
  connection.Open();
  using (var command = connection.CreateCommand())
  {
   command.CommandText = "select count(1) from messages";

   var count = command.ExecuteScalar();

   Console.WriteLine($"記錄條數(shù):{count}");

   return Convert.ToInt32(count);
  }
  }
 }

output

記錄條數(shù):75896

2. NetFramework 4.0下ContinueWith的寫(xiě)法

當(dāng)年異步和并發(fā)編程概念特別火，火熱度參考現(xiàn)在的直播帶貨，這個(gè)時(shí)期的C#率先使用新的Task一網(wǎng)兜，在數(shù)據(jù)庫(kù)操作的幾大類(lèi)中開(kāi)始有了Async結(jié)尾的方法，如OpenAsync,ExecuteScalarAsync,ReadAsync 等等,但遺憾的是那時(shí)寫(xiě)異步，只能像下面這樣寫(xiě)。

 public static Task<object> ContinueWithGetCount()
 {
  var connection = new MySqlConnection("server=xxx.xxx.xxx.xxx;userid=xxx;password=xxx;database=xxx;charset=utf8;port=3306;");

  var task = connection.OpenAsync().ContinueWith(t1 =>
  {
   var command = connection.CreateCommand();

   command.CommandText = "select count(1) from messages";

   return command.ExecuteScalarAsync().ContinueWith(t2 =>
         {
         command.Dispose();
         connection.Dispose();

         Console.WriteLine($"記錄條數(shù):{t2.Result}");

         return t2.Result;
         });
  }).Unwrap();


  return task;
 }

output

記錄條數(shù):75896

相比同步代碼，這異步代碼寫(xiě)的是不是很憋屈，為了應(yīng)對(duì)漸進(jìn)式的Async方法，我不得不進(jìn)行ContinueWith的深層嵌套，如果Async更多，那對(duì)可讀性將是毀滅性的打擊，這就是所謂的回調(diào)地獄。

3. NetFramework 4.5 下 await,async的寫(xiě)法

寫(xiě)到這里讓我想起了邢老大的那本自傳書(shū)《左手夢(mèng)想，右手療傷》，這苦這心酸只有真正經(jīng)歷過(guò)的人才會(huì)懂，沒(méi)有人能夠隨隨便便成功，接下來(lái)大家的期望就是如何做到有同步式的代碼又有異步功效，魚(yú)和熊掌我都要，當(dāng)然是可以的，看看如何用await,async進(jìn)行改造。

 public static async Task<int> AsyncGetCount()
 {
  using (var connection = new MySqlConnection("server=xxx.xxx.xxx.xxx;userid=xxx;password=xxx;database=xxx;charset=utf8;port=3306;"))
  {
  await connection.OpenAsync();
  using (var command = connection.CreateCommand())
  {
   command.CommandText = "select count(1) from messages";

   var count = await command.ExecuteScalarAsync();

   Console.WriteLine($"記錄條數(shù):{count}");

   return Convert.ToInt32(count);
  }
  }
 }

output

記錄條數(shù):75896

上面這代碼太簡(jiǎn)潔了，眼花的朋友還以為是同步代碼呢？改造的地方也僅僅是方法簽名處加上一個(gè)async，異步方法前加上await，相當(dāng)于痛苦版的ContinueWith。

二：案例二【循環(huán)下的異步】

上一個(gè)案例只是使用ExecuteScalarAsync從數(shù)據(jù)庫(kù)中讀取一個(gè)值來(lái)得到表中的記錄數(shù)，在業(yè)務(wù)開(kāi)發(fā)中更多的是使用ExecuteReader從數(shù)據(jù)庫(kù)中獲取批量記錄，這個(gè)就涉及到了如何在循環(huán)中使用異步，想想就太苦難了(┬＿┬)。

1. NetFramework 4.0之前的寫(xiě)法

這里我從messages表中讀取5條記錄，然后輸出到控制臺(tái)，詳細(xì)代碼如下：

 public static List<string> SyncGetMessageList()
 {
  var messageList = new List<string>();
  using (var connection = new MySqlConnection("server=xxx.xxx.xxx.xxx;userid=xxx;password=xxx;database=xxx;charset=utf8;port=3306;"))
  {
  connection.Open();
  using (var command = connection.CreateCommand())
  {
   command.CommandText = "select message from messages limit 5;";
   using (var reader = command.ExecuteReader())
   {
   while (reader.Read())
   {
    messageList.Add(reader.GetString("message"));
   }
   }
  }
  }
  messageList.ForEach(Console.WriteLine);
  return messageList;
 }

output

你需要忘記失去的，感激擁有的，和期待將至的。
以前的找不到了。
對(duì)于編譯錯(cuò)誤，刪除Pods文件夾然后重新pod install已經(jīng)成為經(jīng)驗(yàn)。次。
Hello，Is there anyone here?
放松心情

2. NetFramework 4.0下ContinueWith的寫(xiě)法

要想用ContinueWith完成這功能，最簡(jiǎn)單有效的辦法就是使用遞歸，用遞歸的方式把若干個(gè)ContinueWith串聯(lián)起來(lái)，而要用遞歸的話(huà)還要單獨(dú)定義一個(gè)方法，寫(xiě)的有點(diǎn)亂，大家將就著看吧。

 public class Program
 {
 public static void Main(string[] args)
 {
  var task = ContinueWithAsyncGetMessageList();

  task.Result.ForEach(Console.WriteLine);

  Console.Read();
 }

 public static Task<List<string>> ContinueWithAsyncGetMessageList()
 {
  var connection = new MySqlConnection("server=xxx.xxx.xxx.xxx;userid=xxx;password=xxx;database=xxx;charset=utf8;port=3306;");

  var task = connection.OpenAsync().ContinueWith(t1 =>
  {
   var messageList = new List<string>();

   var command = connection.CreateCommand();

   command.CommandText = "select message from messages limit 5;";

   return command.ExecuteReaderAsync().ContinueWith(t2 =>
   {
   var reader = (MySqlDataReader)t2.Result;
   return GetMessageList(reader, messageList).ContinueWith(t3 =>
   {
    reader.Dispose();
    command.Dispose();
    connection.Dispose();
   });
   }).Unwrap().ContinueWith(t3 => messageList);

  }).Unwrap();

  return task;
 }

 /// <summary>
 /// 采用遞歸處理循環(huán)
 /// </summary>
 /// <param name="reader"></param>
 /// <param name="messageList"></param>
 /// <returns></returns>
 public static Task<List<string>> GetMessageList(MySqlDataReader reader, List<string> messageList)
 {
  var task = reader.ReadAsync().ContinueWith(t =>
  {
   if (t.Result)
   {
   var massage = reader.GetString("message");
   messageList.Add(massage);
   return GetMessageList(reader, messageList);
   }
   else
   {
   return Task.FromResult(new List<string>());
   }
  }).Unwrap();

  return task;
 }
 }

output

你需要忘記失去的，感激擁有的，和期待將至的。
以前的找不到了。
對(duì)于編譯錯(cuò)誤，刪除Pods文件夾然后重新pod install已經(jīng)成為經(jīng)驗(yàn)。次。
Hello，Is there anyone here?
放松心情

在遞歸下探的過(guò)程中把messageList集合給填滿(mǎn)了，而后將messageList返回給調(diào)用端即可，如果沒(méi)看明白，我畫(huà)一張圖吧！

3. NetFramework 4.5 下 await,async的寫(xiě)法

😄，剛剛是不是噩夢(mèng)般經(jīng)歷，救世主來(lái)啦，還是要魚(yú)和熊掌一起兼得

 public static async Task<List<string>> AsyncGetMessageList()
 {
  var messageList = new List<string>();
  using (var connection = new MySqlConnection("server=xxx.xxx.xxx.xxx;userid=xxx;password=xxx;database=xxx;charset=utf8;port=3306;"))
  {
  await connection.OpenAsync();
  using (var command = connection.CreateCommand())
  {
   command.CommandText = "select message from messages limit 5;";
   using (var reader = await command.ExecuteReaderAsync())
   {
   while (await reader.ReadAsync())
   {
    messageList.Add(reader["message"].ToString());
   }
   }
  }
  }
  return messageList;
 }

output