线程也疯狂-----异步编程

Posted 2020-08-29 东秦男人

前言

本节主要介绍异步编程中Task、Async和Await的基础知识。

什么是异步？

异步处理不用阻塞当前线程来等待处理完成，而是允许后续操作，直至其它线程将处理完成，并回调通知此线程。

异步和多线程

相同点：避免调用线程阻塞，从而提高软件的可响应性。

不同点：

异步操作无须额外的线程负担，并且使用回调的方式进行处理，在设计良好的情况下，处理函数可以不必使用共享变量（即使无法完全不用，最起码可以减少 共享变量的数量），减少了死锁的可能。C#5.0 .NET4.5 以后关键字Async和Await的使用，使得异步编程变得异常简单。

多线程中的处理程序依然是顺序执行，但是多线程的缺点也同样明显，线程的使用（滥用）会给系统带来上下文切换的额外负担。并且线程间的共享变量可能造成死锁的出现。

异步应用场景及原理

异步主要应用于IO操作，数据库访问，磁盘操作，Socket访问、HTTP/TCP网络通信 

原因：对于IO操作并不需要CPU进行过多的计算，这些数据主要通过磁盘进行处理，如果进行同步通信无法结束，需要创建更多的线程资源，线程的数据上下文频繁的切换也是对资源的浪费，针对IO操作不需要单独的分配一个线程来处理。

举例说明：

操作：服务器接收HTTP请求对数据库进行操作然后返回

同步处理请求的线程会被阻塞，异步处理请求的线程不会阻塞。

 

任务

  在使用任务之前，针对线程的调用大多都用线程池提供的静态方法QueueUserWorkItem,但是这个函数有很多的限制，其中最大的问题就是没有内部机制可以让开发者知道操作在什么时候完成，也没有机制在操作完成时获取返回值，微软为了解决这个问题引入了任务的概念。

 首先构造一个Task<TResult>对象，并为TResult传递返回值，开始任务之后等待它并回去结果，示例代码：

 1 static void Main(string[] args)
 2         {
 3             Console.WriteLine("开始进行计算");
 4            // ThreadPool.QueueUserWorkItem(Sum, 10);
 5             Task<int> task = new Task<int>(Sum, 100);
 6             task.Start();
 7             //显示等待获取结果
 8             task.Wait();
 9             //调用Result时，等待返回结果
10             Console.WriteLine("程序结果为 Sum = {0}",task.Result);
11             Console.WriteLine("程序结束");
12             Console.ReadLine();
13         }
14 
15         public static int Sum(object i)
16         {
17             var sum = 0;
18             for (var j = 0; j <= (int) i; j++)
19             {
20                 Console.Write("{0} + ",sum);
21                 sum += j;
22             }
23             Console.WriteLine( " = {0}",sum);
24             return sum;
25         }

除了wait等待单个任务外，task还提供了等待多个任务，WaitAny和WaitAll，它阻止调用线程，直到数组中所有的Task对象完成。

取消任务

任务的取消同样使用的是.NET Framework的标准取消操作模式，首先需要创建一个CancellationTokenSource对象，然后在函数中加入参数CancellationToken，将CancellationTokenSource的Token传递给方法，然后调用IsCancellationRequested获取是否已经取消该值进行判断。

 1 static void Main(string[] args)
 2         {
 3             Console.WriteLine("开始进行计算");
 4             // ThreadPool.QueueUserWorkItem(Sum, 10);
 5             var  ctx = new CancellationTokenSource();
 6             var task = new Task<int>(() => Sum(ctx.Token, 100000));
 7             task.Start();
 8             //显示等待获取结果
 9             //task.Wait(ctx.Token);
10             Thread.Sleep(1000);
11             ctx.Cancel();
12             //调用Result时，等待返回结果
13             Console.WriteLine("程序结果为 Sum = {0}", task.Result);
14             Console.WriteLine("程序结束");
15             Console.ReadLine();
16         }
17 
18         public static int Sum(CancellationToken cts, object i)
19         {
20             var sum = 0;        
21             for (var j = 0; j <= (int)i; j++)
22             {
23                 if (cts.IsCancellationRequested) return sum;
24                 Thread.Sleep(50);
25                 Console.Write("{0} + ", sum);
26                 sum += j;
27             }
28             Console.WriteLine(" = {0}", sum);
29             return sum;
30         }

任务完成后自动启动新任务

实际的开发应用中，经常出现一次任务完成后立刻启动另外一个任务，并且不能够使线程阻塞，在任务尚未完成时调用result会使程序阻塞，无法查看任务的执行进度，TASK提供了一个方法ContinueWith，它不会阻塞任何线程，当第一个任务完成时，会立即启动第二个任务。

 1 static void Main(string[] args)
 2         {
 3             Console.WriteLine("开始进行计算");
 4             // ThreadPool.QueueUserWorkItem(Sum, 10);
 5             var  ctx = new CancellationTokenSource();
 6             var task = new Task<int>(() => Sum(ctx.Token, 100000));
 7             task.Start();
 8             var cwt = task.ContinueWith(p =>
 9             {
10                 Console.WriteLine("task result ={0} ",task.Result);
11             });
12             //显示等待获取结果
13             //task.Wait(ctx.Token);
14             Thread.Sleep(1000);
15             ctx.Cancel();
16             //调用Result时，等待返回结果
17             Console.WriteLine("程序结果为 Sum = {0}", task.Result);
18             Console.WriteLine("程序结束");
19             Console.ReadLine();
20         }
21 
22         public static int Sum(CancellationToken cts, object i)
23         {
24             var sum = 0;        
25             for (var j = 0; j <= (int)i; j++)
26             {
27                 if (cts.IsCancellationRequested) return sum;
28                 Thread.Sleep(50);
29                 Console.Write("{0} + ", sum);
30                 sum += j;
31             }
32             Console.WriteLine(" = {0}", sum);
33             return sum;
34         }

Async&Await 简单使用

使用Async&Await的主要目的是方便进行异步操作，因为.net 4.0 以前进行异步操作时比较复杂的，主要是通过调用微软提供的异步回调方法进行编程，如果遇到需要自己实现的方法显得非常头疼，.net的各个版本都有自己主推的技术,像.NET1.1中的委托，.NET2.0中的泛型，.NET3.0中的Linq，.NET4.0中的Dynimac,.net4.5主推的就是异步编程，大家只需要了解TASK+异步函数就可以实现异步编程。

async：告诉CLR这是一个异步函数。

await:  将Task<TResult>返回值的函数进行异步处理。

 

示例目的：获取网址JS代码，并在界面显示。

 1  private static async Task<string> DownloadStringWithRetries(string uri)
 2         {
 3             using (var client = new HttpClient())
 4             {
 5                 // 第1 次重试前等1 秒，第2 次等2 秒，第3 次等4 秒。
 6                 var nextDelay = TimeSpan.FromSeconds(1);
 7                 for (int i = 0; i != 3; ++i)
 8                 {
 9                     try
10                     {
11                         return await client.GetStringAsync(uri);
12                     }
13                     catch
14                     {
15                     }
16                     await Task.Delay(nextDelay);
17                     nextDelay = nextDelay + nextDelay;
18                 }
19                 // 最后重试一次，以便让调用者知道出错信息。
20                 return await client.GetStringAsync(uri);
21             }
22         }

 1  static  void Main(string[] args)
 2         {
 3             Console.WriteLine("获取百度数据");
 4             ExecuteAsync();
 5             Console.WriteLine("线程结束");
 6             Console.ReadLine();
 7         }
 8 
 9         public static async void ExecuteAsync()
10         {
11            string text = await DownloadStringWithRetries("http://wwww.baidu.com");
12            Console.WriteLine(text);
13         }

运行结果发现，首先获取百度数据，线程结束，最后显示html代码，这是因为异步开启了新的线程，并不会造成线程阻塞。