异步编程(async 和 await)
1.概念
异步编程是一项关键技术,可以直接处理多个核心上的I/O阻塞和并发操作
2.使用场景
对于存在IO密集型(例如从网路请求数据、访问数据库和写入到文件系统)和CPU密集型(例如大量的计算)的任务可以选择异步编程
3.异步编程针对于IO密集型任务的优点
针对于服务器端和客户端分别描述
服务器端:
a:由于没有专门的用于阻止未完成任务的线程,因此服务器线程可以服务更多的Web请求。
b:现模拟假设一个场景,有两台服务器,都只有5个线程可用于服务请求,一台运行异步代码,一台不运行异步代码。
假设这两台服务器都接收6个并发请求,每个请求执行一个I/O操作,未运行异步代码的服务器必须对6个请求排队直到5个线程中的一个完成了I/O密集型工作并编写了响应。假如此时收到了20个请求,由于队列太长,服务器可能开始变慢。运行有异步代码的服务器也需要对6个请求排队,但由于使用了async 和 await,I/O密集型工作开始时,每个线程都会得到释放,无需等到工作结束,收到第20个请求时,传入请求队列将变得很小(如果其中还有请求的话),且服务器不会变慢。
c:由于I/O操作在CPU上几乎没有耗时,所以将整个CPU线程专用于执行几乎没有任何作用的工作将是一种资源浪费。
客户端:
a:使用了async和await对于客户端应用带来的最大好处在于提高了响应能力。例如:手机游戏等应用,在涉及IO时尽可能少的影响UI线程,这点至关重要。
4.异步编程针对于CPU密集型任务的优点
服务器端:
使用异步编程可以开启另外一个线程来处理这一个CPU密集型的任务,另外一个线程就有可能是多核CPU情况下的另一个核,从而充分的利用了多核CPU的优势。
客户端:
此优点和上述针对IO密集型任务的一致
5.I/O密集型和CPU密集型任务的异步编程模型
大多数场景下:
对于I/O密集型,await 异步方法(aysnc修饰的返回Task或者Task<T>)
对于CPU密集型,await 异步方法(Task.Run()一个新的任务)
6.示例代码展示
I/O密集型:
private static readonly HttpClient s_client = new HttpClient();
static async Task Main(string[] args)
{
Console.WriteLine("ThreadId:"+Thread.CurrentThread.ManagedThreadId);
var result = await GetHtmlAsync();
Console.WriteLine("内容长度:"+result.Length);
Console.WriteLine("ThreadId:" + Thread.CurrentThread.ManagedThreadId);
}
static Task<string> GetHtmlAsync()
{
Console.WriteLine("ThreadId:" + Thread.CurrentThread.ManagedThreadId);
var uri = new Uri("https://www.dotnetfoundation.org");
return s_client.GetStringAsync(uri);
}
输出的结果是:
Main方法执行到await之后,开始调用GetHtmlAsync方法,这个过程仍然是由线程1在进行,当代码执行到s_client.GetStringAsync(uri)之后,此时会将工作委托给操作系统,线程1此时可以被调度去处理其余的任务,s_client.GetStringAsync(uri)完成之后,此时是从CPU调度出新的空闲线程来执行接下来的任务,也就是输出的线程7
使用await关键字不会开启新的线程,只有await后面跟的是类似于GetStringAsync等内置的.NET异步方法,或者自定义的异步方法(方法内部使用了Task.Run或者Task.Factory.StartNew开启了新的Task)
CPU密集型:
static async Task Main(string[] args)
{
Console.WriteLine("Main1:" + Thread.CurrentThread.ManagedThreadId);
Task<long> task = Task.Run(() => BigComputeTest());
long result = 0;
int sum = 0;
for (int i = 0; i < 10000; i++)
{
sum += i;
}
Console.WriteLine("Main2:" + Thread.CurrentThread.ManagedThreadId);
result = await task;
Console.WriteLine($"sum:{sum},result:{result}");
Console.WriteLine("Main3:" + Thread.CurrentThread.ManagedThreadId);
}
static long BigComputeTest()
{
Console.WriteLine("BigComputeTest1:" + Thread.CurrentThread.ManagedThreadId);
long sum = 0;
for (long i = 0; i < 100000000; i++)
{
sum += i;
}
return sum;
}
输出的结果是:
Main方法执行到Task.Run(() => BigComputeTest())时,开启一个新的线程去执行BigComputeTest方法,于此同时可以去执行Main方法中的任务,从计算量上分析,Main方法中的计算会先执行完,因为先输出"Main2:1",执行到await Task时Main方法会等待BigComputeTest执行完,线程1会空闲下来去处理其它的事情,直到BigComputeTest()执行完,Main方法中的余下代码会继续执行,此时执行的话是由执行BigComputeTest方法的线程4来进行的。
结尾
本篇博客中一些描述如有错误,请大家指正