C#实现基于任务的异步编程模式
作者：Ruby_Lu 发布时间：2023-01-08 19:21:15
一.延续任务
private async static void CallerWithAsync()
{
string result = await GreetingAsync("Stephanie");
Console.WriteLine(result);
}
static Task<string> GreetingAsync(string name)
{
return Task.Run<string>(() =>
{
Thread.Sleep(10000);
return name;
});
}
GreetingAsync方法返回一个Task<string>对象。该Task<string>对象包含任务创建的信息，并保存到任务完成。Task类的ContinueWith方法定义了任务完成后就调用的代码。
private static void CallerWithContinuationTask()
{
var t1 = GreetingAsync("Stephanie");
t1.ContinueWith(t =>
{
string result = t.Result;
Console.WriteLine(result);
});
}
由于不使用await,线程不会在方法中等待，会执行完CallerWithContinuationTask()的代码。不会再ContinueWith这里等待，所以需要一个前台线程，不然会关闭所以线程。
二.同步上下文
CallerWithAsync和CallerWithContinuationTask方法在方法的不同阶段使用了不同的线程。
static Task<string> GreetingAsync(string name)
{
return Task.Run<string>(() =>
{
Thread.Sleep(10000);
Console.WriteLine("running greetingasync in thread {0} and task {1}", Thread.CurrentThread.ManagedThreadId, Task.CurrentId);
return name;
});
}
private async static void CallerWithAsync()
{
Console.WriteLine("started CallerWithAsync in thread {0} and task {1}", Thread.CurrentThread.ManagedThreadId, Task.CurrentId);
string result = await GreetingAsync("Stephanie");
Console.WriteLine(result);
Console.WriteLine("finished GreetingAsync in thread {0} and task {1}", Thread.CurrentThread.ManagedThreadId, Task.CurrentId);
}
private static void CallerWithContinuationTask()
{
Console.WriteLine("started CallerWithContinuationTask in thread {0} and task {1}", Thread.CurrentThread.ManagedThreadId, Task.CurrentId);
var t1 = GreetingAsync("Stephanie");
t1.ContinueWith(t =>
{
string result = t.Result;
Console.WriteLine(result);
Console.WriteLine("finished CallerWithContinuationTask in thread {0} and task {1}", Thread.CurrentThread.ManagedThreadId, Task.CurrentId);
});
}
使用async和await关键字，当await完成后，不需要进行任何处理，就能访问UI线程。默认情况下，生成的代码就会把线程转换到拥有同步上下文的线程中。调用异步方法的线程分配给了同步上下文，await完成之后将继续执行。
如果不使用相同的同步上下文，必须调用Task类的ConfigureAwait(false).例如，一个WPF应用程序，其await后面的代码没有任何用到UI元素的代码。在这种情况下，避免切换到同步上下文会执行的更快。
string s1 = await GreetingAsync("Stephanie").ConfigureAwait(false);
三.使用多个异步方法
在一个异步方法里，可以调用一个或多个异步方法。如何编写代码，取决于一个异步方法的结果是否取决于另一个异步方法。
1.按顺序调用异步方法
下面的例子，第第二个异步方法依赖于第一个异步方法的结果，await关键字就很有用。
private async static void MultipleAsyncMethods()
{
string s1 = await GreetingAsync("Stephanie");
string s2 = await GreetingAsync(s1);
Console.WriteLine("Finished both methods.\n Result 1: {0}\n Result 2: {1}", s1, s2);
}
2.使用组合器
如果第二个异步方法独立于第一个，每个异步方法可以都不使用await，而是把每个异步方法的返回结果赋值给Task变量，就会运行的更快。
private async static void MultipleAsyncMethodsWithCombinators1()
{
Task<string> t1 = GreetingAsync("Stephanie");
Task<string> t2 = GreetingAsync("Matthias");
await Task.WhenAll(t1, t2);
Console.WriteLine("Finished both methods.\n Result 1: {0}\n Result 2: {1}", t1.Result, t2.Result);
}
Task.WhenAll组合器可以接受多个同一类型的参数，并返回同一类型的值。
Task.WhenAll是在所有传入方法的任务都完成了才返回Task。
WhenAny是在其中一个传入方法的任务完成了就返回。
Task.WhenAll定义了几个重载版本。如果所有的任务返回相同的类型，那么该类型的数组可用于await返回的结果。
string[] result = await Task.WhenAll(t1, t2);
四.转换异步模式
https://www.jb51.net/article/244023.htm讲了三种异步编程的模式。
并非所有的.NET Framework类在.NET 4.5中都引入了新的异步方法。还有许多类只提供类BeginXXX和EndXXX方法的异步模式，可以使用TaskFactory类的FromAsync方法，它可以把使用异步模式的方法转换为基于任务的异步模式的方法。
/创建一个委托，并引用同步方法Greeting
private static Func<string, string> greetingInvoker = Greeting;
static IAsyncResult BeginGreeting(string name, AsyncCallback callback, object state)
{
return greetingInvoker.BeginInvoke(name, callback, state);
}
static string EndGreeting(IAsyncResult ar)
{
return greetingInvoker.EndInvoke(ar);
}
//FromAsync方法的前两个参数是委托类型，传入BeginGreeting, EndGreeting的地址。后两个参数是输入的参数和对象状态参数。
private static async void ConvertingAsyncPattern()
{
string r = await Task<string>.Factory.FromAsync<string>(BeginGreeting, EndGreeting, "Angela", null);
Console.WriteLine(r);
}
五.错误处理
如果调用异步方法没有等待，将异步方法放在try/catch中，就不捕获不到异常。
private static void DontHandle()
{
try
{
ThrowAfter(200, "first");
// exception is not caught because this method is finished before the exception is thrown
}
catch (Exception ex)
{
Console.WriteLine(ex.Message);
}
}
static async Task ThrowAfter(int ms, string message)
{
Console.Write("xxx");
await Task.Delay(ms);
throw new Exception(message);
}
DontHandle方法调用ThrowAfter后，不会在该处等待，会继续执行，不再保持对ThrowAfter方法的引用。
注意：返回void的异步方法永远不会等待.异步方法最好返回一个Task类型。
1.异步方法的异常处理
使用await关键字，将其放在在try/catch中
private static async void HandleOneError()
{
try
{
await ThrowAfter(2000, "first");
}
catch (Exception ex)
{
Console.WriteLine("handled {0}", ex.Message);
}
}
2.多个异步方法的异常处理
如果按照下面的代码，第二个异常将不会抛出。因为第一个异常已经抛出，直接调到catch块内了。
private static async void StartTwoTasks()
{
try
{
await ThrowAfter(2000, "first");
await ThrowAfter(1000, "second"); // the second call is not invoked because the first method throws an exception
}
catch (Exception ex)
{
Console.WriteLine("handled {0}", ex.Message);
}
}
使用Task.WhenAll,不管任务是否抛出异常，都会等到两个任务完成。所以会抛出两个异常。
但是，只能看见传递给Task.WhenAll方法的第一个任务的异常信息，虽然第二个异常会抛出，但不会显示：
private async static void StartTwoTasksParallel()
{
Task t1 = null;
Task t2 = null;
try
{
t1 = ThrowAfter(2000, "first");
t2 = ThrowAfter(1000, "second");
await Task.WhenAll(t1, t2);
}
catch (Exception ex)
{
// just display the exception information of the first task that is awaited within WhenAll
Console.WriteLine("handled {0}", ex.Message);
}
}
3.使用AggregateException信息返回显示异常
将Task.WhenAll返回的结果写到一个Task变量中，catch语句只检索到第一个任务的异常，但可以访问外部任务taskResult的Exception属性。Exception属性是AggregateException类型。这个异常类型定义了InnerExceptions属性，它包含了等待中的所有异常的列表。
private static async void ShowAggregatedException()
{
Task taskResult = null;
try
{
Task t1 = ThrowAfter(2000, "first");
Task t2 = ThrowAfter(1000, "second");
await (taskResult = Task.WhenAll(t1, t2));
}
catch (Exception ex)
{
// just display the exception information of the first task that is awaited within WhenAll
Console.WriteLine("handled {0}", ex.Message);
foreach (var ex1 in taskResult.Exception.InnerExceptions)
{
Console.WriteLine("inner exception {0} from task {1}", ex1.Message, ex1.Source);
}
}
}
六.取消异步方法
如果后台任务可能运行很长时间，就可能用的取消任务。
取消框架基于协助行为，不是强制性的。一个运行时间很长的任务需要检查自己是否被取消，在这种情况下，它的工作就是清理所有已打开的资源，并结束相关工作。
取消基于CancellationTokenSource类，该类可用于发送取消请求。请求发送给引用CancellationToken类的任务，其中CancellationToken类和CancellationTokenSource相关联。
private CancellationTokenSource cts = new CancellationTokenSource();
//添加一个按钮，用于取消正在运行的任务。使用cts.Cancel();
private void button5_Click(object sender, EventArgs e)
{
if (cts != null)
cts.Cancel();
}
private async void button4_Click(object sender, EventArgs e)
{
string s = await AsyncTaskTest();
}
//向Task类的Run方法传递CancellationToken参数。但需要检查是否请求了取消操作。
Task<string> AsyncTaskTest()
{
return Task.Run(() =>
{
cts.Token.ThrowIfCancellationRequested();
Thread.Sleep(5000);
return "异步完成";
}
, cts.Token);
}
来源：https://www.cnblogs.com/afei-24/p/6758058.html
0
投稿猜你喜欢
题外话： 泛型与通配符是Java语法中比较难懂的两个语法，学习泛型和通配符的主要目的是能够看懂源码，实际使用的不多。1.泛型1.1泛型的用法- 本文介绍了详解Android中PopupWindow在7.0后适配的解决，分享给大家，具体如下：这里主要记录一次踩坑的经历。需求：如上图左侧
- 看到群里还有小伙伴说公司里还特别建了800+人的群在处理...好在很快就有了缓解措施和解决方案。同时，log4j2官方也是速度影响发布了最新
- Interfaces 接口在软件工程中，由一份“契约”规定来自不同的开发小组的软件之间如何相互作用是非常常见的。每个小组都可以在不知道别的组
- Java栈之链式栈存储结构实现一、链栈采用单链表来保存栈中所有元素，这种链式结构的栈称为链栈。二、栈的链式存储结构实现package com
- 一、项目简述功能：宿舍管理员，最高管理员，学生三个身份，包括学 生管理，宿舍管理员管理，考勤管理，宿舍楼管理，缺勤 记录管理，个人信息修改等
- 优点1.观察者和被观察者是抽象耦合的。2.建立一套触发机制。缺点1.如果一个被观察者对象有很多的直接和间接的观察者的话，将所有的观察者都通知
- 虽然项目中都夹杂了Hibernate的支持，但是团队开发中，很多人为了编写特殊查询的代码时都使用了JDBC进行查询。JDBC查询后返回的是一
- 本文实例讲述了C#使用虚拟方法实现多态。分享给大家供大家参考。具体分析如下：我们看一个例子，假若有一个动物类，类中用方法cry()描述动物的
- 前言去年在公司参与了一个某某机场建设智能机场的一个项目，人脸登机是其中的一个功能模块，当时只是写了后台的接口，调用人脸识别设备的api，给闸
- 要实现摇一摇的功能，类似于微信的摇一摇方法1：通过分析加速计数据来判断是否进行了摇一摇操作（比较复杂）方法2：iOS自带的Shake监控AP
- 本文实例讲述了C#实现文件断点续传下载的方法。分享给大家供大家参考。具体实现方法如下：using System;using System.D
- 文件名：page.xml<RelativeLayout xmlns:android="http://schemas.andr
- 简介lombok是一个编译级别的插件，它可以在项目编译的时候生成一些代码。比如日常开发过程中需要生产大量的JavaBean文件，每个Java
- 通常我们用惯的ListView每一项的布局都是相同的，只是控件所绑定的数据不同。但单单只是如此并不能满
- 先建个钉钉群，并加好机器人此时，机器人已经添加完毕，接下来编写我们连接机器人小哥的代码import com.alibaba.fastjson
- 前文传送门：Netty分布式Future与Promise执行回调相关逻辑剖析概述FastThreadLocal我们在剖析堆外内存分配的时候简
- 1.JMM数据原子操作read(读取)∶从主内存读取数据load(载入):将主内存读取到的数据写入工作内存use(使用):从工作内存读取数据
- 本文研究的主要内容是Java编程二项分布的递归和非递归实现，具体如下。问题来源：算法第四版 第1.1节 习题27：return (1.0 -
- 本文实例讲述了Java类加载器和类加载机制。分享给大家供大家参考，具体如下：一 点睛1 类加载器负责将.class文件（可能在磁盘上，也可能
