一文搞懂c# await,async执行流 - 网站

一文搞懂c# await,async执行流

分类：其他教程 · 发布时间：2021-10-04 20:12 · 阅读：10580

这篇文章主要介绍了c# await，async执行流的相关知识，文章讲解的非常细致，代码帮助理解和学习，感兴趣的朋友可以了解下

昨天有朋友在公众号发消息说看不懂await，async执行流，其实看不懂太正常了，因为你没经过社会的毒打，没吃过牢饭就不知道自由有多重要，没生过病就不知道健康有多重要，没用过ContinueWith就不知道await,async有多重要，下面我举两个案例佐证一下？

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

写了这么多年的程序，相信大家都知道连接数据库少不了这几个对象，DbConnection，DbCommand，DbDataReader等等。。先来看看ContinueWith在连接数据库时嵌套过深的尴尬。

1. NetFramework 4.0之前的写法

这个时期的代码没有什么好说的，都是程式代码，一撸到底，简洁明了。

 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($"记录条数:{count}"); return Convert.ToInt32(count); } } }

output

记录条数:75896

2. NetFramework 4.0下ContinueWith的写法

当年异步和并发编程概念特别火，火热度参考现在的直播带货，这个时期的C#率先使用新的Task一网兜，在数据库操作的几大类中开始有了Async结尾的方法，如OpenAsync,ExecuteScalarAsync,ReadAsync 等等,但遗憾的是那时写异步，只能像下面这样写。

 public static Task 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($"记录条数:{t2.Result}"); return t2.Result; }); }).Unwrap(); return task; }
output
记录条数:75896
相比同步代码，这异步代码写的是不是很憋屈，为了应对渐进式的Async方法，我不得不进行ContinueWith的深层嵌套，如果Async更多，那对可读性将是毁灭性的打击，这就是所谓的回调地狱。
3. NetFramework 4.5 下 await,async的写法
写到这里让我想起了邢老大的那本自传书《左手梦想，右手疗伤》，这苦这心酸只有真正经历过的人才会懂，没有人能够随随便便成功，接下来大家的期望就是如何做到有同步式的代码又有异步功效，鱼和熊掌我都要，当然是可以的，看看如何用await,async进行改造。
 public static async Task 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($"记录条数:{count}"); return Convert.ToInt32(count); } } }
output
记录条数:75896
上面这代码太简洁了，眼花的朋友还以为是同步代码呢？ 改造的地方也仅仅是方法签名处加上一个async，异步方法前加上await，相当于痛苦版的ContinueWith。
二：案例二 【循环下的异步】
上一个案例只是使用ExecuteScalarAsync从数据库中读取一个值来得到表中的记录数，在业务开发中更多的是使用ExecuteReader从数据库中获取批量记录，这个就涉及到了如何在循环中使用异步，想想就太苦难了(┬＿┬)。
1. NetFramework 4.0之前的写法
这里我从messages表中读取5条记录，然后输出到控制台，详细代码如下：
 public static List SyncGetMessageList() { var messageList = new List(); 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
你需要忘记失去的，感激拥有的，和期待将至的。
 以前的找不到了。
 对于编译错误，删除Pods文件夹然后重新pod install已经成为经验。次。
 Hello，Is there anyone here?
 放松心情    
2. NetFramework 4.0下ContinueWith的写法
要想用ContinueWith完成这功能，最简单有效的办法就是使用递归，用递归的方式把若干个ContinueWith串联起来，而要用递归的话还要单独定义一个方法，写的有点乱，大家将就着看吧。
 public class Program { public static void Main(string[] args) { var task = ContinueWithAsyncGetMessageList(); task.Result.ForEach(Console.WriteLine); Console.Read(); } public static Task> 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(); 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; } ///  /// 采用递归处理循环 ///  ///  ///  ///  public static Task> GetMessageList(MySqlDataReader reader, List 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()); } }).Unwrap(); return task; } }
output
你需要忘记失去的，感激拥有的，和期待将至的。
 以前的找不到了。
 对于编译错误，删除Pods文件夹然后重新pod install已经成为经验。次。
 Hello，Is there anyone here?
 放松心情    
在递归下探的过程中把messageList集合给填满了，而后将messageList返回给调用端即可，如果没看明白，我画一张图吧！
在递归下探的过程中把messageList集合给填满了，而后将messageList返回给调用端即可，如果没看明白，我画一张图吧！
3. NetFramework 4.5 下 await,async的写法
                    
        
        
                

            标签：
            

                                c#
                                await
                                async
                                执行流
                            

        

            
    
        

        
相关文章

        

                        
                
C# async/await任务超时处理的实现

                
本文主要介绍了C# async/await任务超时处理的实现，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧

            
                        
                
C#生成比较短的Token字符串

                
这篇文章介绍了C#生成Token字符串的方法，文中通过示例代码介绍的非常详细。对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下

            
                        
                
C#中将dateTimePicker初始值设置为空

                
本文主要介绍了C#中将dateTimePicker初始值设置为空，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧

            
                        
                
一文详解Go语言中的有限状态机FSM

                
有限状态机（Finite State Machine，FSM）是一种数学模型，用于描述系统在不同状态下的行为和转移条件。本文主要来和大家简单讲讲Go语言中的有限状态机FSM的使用，需要的可以参考一下

            
                        
                
C#中程序自删除实现方法

                
这篇文章主要介绍了C# 程序自删除实现方法，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教

            
                    

    

        
    


    
    

        

            

                
© 2026 0133技术栈。All Rights Reserved.