说说C#的async和await

r囧r小猫 2022-07-15 11:49 113阅读 0赞

# [说说C\#的async和await ][C_async_await] #

2013-12-30 10:36  82169人阅读 [评论][Link 1](19) 收藏 [举报][Link 2]

本文章已收录于：

![category_icon.jpg][] 分类：

编程技术*（6）* ![arrow_triangle_20_down.jpg][] ![arrow_triangle_up.jpg][]

[作者同类文章][Link 3] *X*

C\# 5.0中引入了async 和 await。这两个关键字可以让你更方便的写出异步代码。

看个例子：

**\[csharp\]** [ view plain][view plain] [ copy][view plain] [ print][view plain] [?][view plain] [![在CODE上查看代码片][CODE]][CODE_CODE] [![派生到我的代码片][ico_fork.svg]][ico_fork.svg 1]

1.  public class MyClass  
2.  \{  
3.      public MyClass()  
4.      \{  
5.          DisplayValue(); //这里不会阻塞  
6.          System.Diagnostics.Debug.WriteLine("MyClass() End.");  
7.      \}  
8.      public Task<double> GetValueAsync(double num1, double num2)  
9.      \{  
10.         return Task.Run(() =>  
11.         \{  
12.             for (int i = 0; i < 1000000; i++)  
13.             \{  
14.                 num1 = num1 / num2;  
15.             \}  
16.             return num1;  
17.         \});  
18.     \}  
19.     public async void DisplayValue()  
20.     \{  
21.         double result = await GetValueAsync(1234.5, 1.01);//此处会开新线程处理GetValueAsync任务，然后方法马上返回  
22.         //这之后的所有代码都会被封装成委托，在GetValueAsync任务完成时调用  
23.         System.Diagnostics.Debug.WriteLine("Value is : " + result);  
24.     \}  
25. \}

![save_snippets.png][]

public class MyClass
    {
    	public MyClass()
    	{
    		DisplayValue(); //这里不会阻塞
    		System.Diagnostics.Debug.WriteLine("MyClass() End.");
    	}
    	public Task<double> GetValueAsync(double num1, double num2)
    	{
    		return Task.Run(() =>
    		{
    			for (int i = 0; i < 1000000; i++)
    			{
    				num1 = num1 / num2;
    			}
    			return num1;
    		});
    	}
    	public async void DisplayValue()
    	{
    		double result = await GetValueAsync(1234.5, 1.01);//此处会开新线程处理GetValueAsync任务，然后方法马上返回
    		//这之后的所有代码都会被封装成委托，在GetValueAsync任务完成时调用
    		System.Diagnostics.Debug.WriteLine("Value is : " + result);
    	}
    }

上面在MyClass的构造函数里调用了async关键字标记的异步方法DisplayValue()，DisplayValue()方法里执行了一个await关键字标记的异步任务GetValueAsync()，这个异步任务必须是以Task或者Task<TResult>作为返回值的，而我们也看到，异步任务执行完成时实际返回的类型是void或者TResult，DisplayValue()方法里await GetValueAsync()之后的所有代码都会在异步任务完成时才会执行。

DisplayValue()方法实际执行的代码如下：

1.  public void DisplayValue()  
2.  \{  
3.      System.Runtime.CompilerServices.TaskAwaiter<double> awaiter = GetValueAsync(1234.5, 1.01).GetAwaiter();  
4.      awaiter.OnCompleted(() =>  
5.          \{  
6.              double result = awaiter.GetResult();  
7.              System.Diagnostics.Debug.WriteLine("Value is : " + result);  
8.          \});  
9.  \}

![save_snippets.png][]

public void DisplayValue()
    {
    	System.Runtime.CompilerServices.TaskAwaiter<double> awaiter = GetValueAsync(1234.5, 1.01).GetAwaiter();
    	awaiter.OnCompleted(() =>
    		{
    			double result = awaiter.GetResult();
    			System.Diagnostics.Debug.WriteLine("Value is : " + result);
    		});
    }

可以看到，async和await关键字只是把上面的代码变得更简单易懂而已。

程序的输出如下：

MyClass() End.

Value is : 2.47032822920623E-322

以下是我写的一个静态类，可以方便将一个普通Function执行异步调用：

1.  public static class TaskAsyncHelper  
2.  \{  
3.      /// <summary>  
4.      /// 将一个方法function异步运行，在执行完毕时执行回调callback  
5.      /// </summary>  
6.      /// <param name="function">异步方法，该方法没有参数，返回类型必须是void</param>  
7.      /// <param name="callback">异步方法执行完毕时执行的回调方法，该方法没有参数，返回类型必须是void</param>  
8.      public static async void RunAsync(Action function, Action callback)  
9.      \{  
10.         Func<System.Threading.Tasks.Task> taskFunc = () =>  
11.         \{  
12.             return System.Threading.Tasks.Task.Run(() =>  
13.             \{  
14.                 function();  
15.             \});  
16.         \};  
17.         await taskFunc();  
18.         if (callback != null)  
19.             callback();  
20.     \}  
21.   
22.     /// <summary>  
23.     /// 将一个方法function异步运行，在执行完毕时执行回调callback  
24.     /// </summary>  
25.     /// <typeparam name="TResult">异步方法的返回类型</typeparam>  
26.     /// <param name="function">异步方法，该方法没有参数，返回类型必须是TResult</param>  
27.     /// <param name="callback">异步方法执行完毕时执行的回调方法，该方法参数为TResult，返回类型必须是void</param>  
28.     public static async void RunAsync<TResult>(Func<TResult> function, Action<TResult> callback)  
29.     \{  
30.         Func<System.Threading.Tasks.Task<TResult>> taskFunc = ()=>  
31.             \{  
32.                 return System.Threading.Tasks.Task.Run(()=>  
33.                     \{  
34.                         return function();  
35.                     \});  
36.             \};  
37.         TResult rlt = await taskFunc();  
38.         if(callback != null)  
39.             callback(rlt);  
40.     \}  
41. \}

![save_snippets.png][]

public static class TaskAsyncHelper
    	{
    		/// <summary>
    		/// 将一个方法function异步运行，在执行完毕时执行回调callback
    		/// </summary>
    		/// <param name="function">异步方法，该方法没有参数，返回类型必须是void</param>
    		/// <param name="callback">异步方法执行完毕时执行的回调方法，该方法没有参数，返回类型必须是void</param>
    		public static async void RunAsync(Action function, Action callback)
    		{
    			Func<System.Threading.Tasks.Task> taskFunc = () =>
    			{
    				return System.Threading.Tasks.Task.Run(() =>
    				{
    					function();
    				});
    			};
    			await taskFunc();
    			if (callback != null)
    				callback();
    		}
    
    		/// <summary>
    		/// 将一个方法function异步运行，在执行完毕时执行回调callback
    		/// </summary>
    		/// <typeparam name="TResult">异步方法的返回类型</typeparam>
    		/// <param name="function">异步方法，该方法没有参数，返回类型必须是TResult</param>
    		/// <param name="callback">异步方法执行完毕时执行的回调方法，该方法参数为TResult，返回类型必须是void</param>
    		public static async void RunAsync<TResult>(Func<TResult> function, Action<TResult> callback)
    		{
    			Func<System.Threading.Tasks.Task<TResult>> taskFunc = ()=>
    				{
    					return System.Threading.Tasks.Task.Run(()=>
    						{
    							return function();
    						});
    				};
    			TResult rlt = await taskFunc();
    			if(callback != null)
    				callback(rlt);
    		}
    	}

使用很简单，将方法名作为参数传进去就行了，最常用的是把很耗时的序列化函数传进去，以免阻塞UI进程，造成卡顿现象，影响用户体验。

顶

踩

*  上一篇[wp8里通过Uri启动另一个应用程序][wp8_Uri]
 *  下一篇[LongListSelector的Item里使用Image加载网络图片必须注意的问题][LongListSelector_Item_Image]

[C_async_await]: http://blog.csdn.net/tianmuxia/article/details/17675681
[Link 1]: http://blog.csdn.net/tianmuxia/article/details/17675681/#comments
[Link 2]: http://blog.csdn.net/tianmuxia/article/details/17675681/#report
[category_icon.jpg]: /images/20220715/1f6d3d4887d641b687c06a984258d695.png
[arrow_triangle_20_down.jpg]: http://static.blog.csdn.net/images/arrow_triangle%20_down.jpg
[arrow_triangle_up.jpg]: /images/20220715/d9fbb0a31f8c48368957247053762175.png
[Link 3]: http://blog.csdn.net/tianmuxia/article/category/1230088
[view plain]: http://blog.csdn.net/tianmuxia/article/details/17675681/#
[CODE]: https://code.csdn.net/assets/CODE_ico.png
[CODE_CODE]: https://code.csdn.net/snippets/134105
[ico_fork.svg]: https://code.csdn.net/assets/ico_fork.svg
[ico_fork.svg 1]: https://code.csdn.net/snippets/134105/fork
[save_snippets.png]: /images/20220715/e1e716844dae4732839d444315f9c763.png
[wp8_Uri]: http://blog.csdn.net/tianmuxia/article/details/9449619
[LongListSelector_Item_Image]: http://blog.csdn.net/tianmuxia/article/details/17791151