C# Task async/await CancellationToken

C# Task / async/await / CancellationToken一、Task1.Task 理解Task类似于我们去点餐餐厅给你一张小票这个小票就是Task。他表示现在还没有饭以后会有你可以去逛街等饭做好可以凭借小票(Task)取餐而在C#Task小票做饭一个异步操作可能是读文件、请求网站、查数据库逛街不阻塞当前运行程序代码可以干其他事。需要注意的的是Task 不是线程。这是一个最核心也最容易误解的概念。Task 表示的是一项尚未完成的工作或一个未来的结果它更像一个异步操作的句柄而不是线程本身TaskinttaskGetUserCountAsync();这里的 task 表示用户数量这个结果以后会出来但完全不等于已经为它开了一个新线程。Task 的本质有三层含义异步操作的统一抽象无论底层是线程池执行计算、操作系统完成异步 I/O、定时器触发还是回调被包装最后都可以统一表现为一个Task 或 Task。带有状态一个 Task 会经历等待调度、运行中、成功完成、失败或被取消等状态它还负责承载完成信号、异常、取消状态和 continuation。可组合Task 可以被组合使用这是相比传统回调最重要的优势之一。2. Task 的生命周期Created 任务已创建但尚未启动Running 任务正在执行RanToCompletion 任务成功完成没有异常或取消Faulted 任务因未处理的异常而失败Canceled 任务被取消视觉开发重点关心Faulted和 Canceled3. 常用 Task 组合器方法作用视觉案例Task.WhenAll并行执行多个任务同时处理多台相机的采集Task.WhenAny谁先完成就用谁的结果多个算法模型并行推理取最快结果Task.Delay非阻塞等待定时轮询设备状态不影响 UI二、async/await 写同步代码一样写异步逻辑很多人认为 async/await 是某种运行时黑魔法——一个函数加上 async 就能自动变成非阻塞加上 await 就能让线程“休息”而不会阻塞。实际上async/await 完全是由编译器在编译期完成的状态机重写。运行时并不知道 async 关键字的存在它看到的是经过转换的代码。换句话说async/await 是 C# 编译器提供的高级语法糖它自动帮你将异步逻辑切分成多个片段并在每个 await 点保存/恢复状态。1. await 的等待到底等什么await 的本质不阻塞只是“挂起并返回”很多人误以为 await task; 会让当前线程阻塞等待 task 完成这种理解是完全错误的。await 的行为是检查 task 是否已经完成IsCompleted true如果是同步继续不需要任何额外调度。如果否进入第 2 步。挂起当前方法保存方法的状态局部变量、执行位置等并立即返回一个未完成的 Task 给调用者。注册一个回调当 task 完成时该回调会恢复当前方法的执行在某个线程上通常是完成 task 的线程或捕获的同步上下文。因此await 不会阻塞任何线程。这正是异步编程能提高吞吐量的核心线程可以被释放去做其他工作而不是白白等待 I/O。对比阻塞等待方式线程行为适用场景task.Wait() 或 task.Result当前线程阻塞直到 task 完成控制台 Main 方法有限场景await task当前方法挂起线程返回调用者不阻塞几乎所有异步场景如果在 UI 线程WPF/WinForms或 ASP.NET Core 请求线程上使用 .Result轻则降低响应性重则导致死锁。何时真的需要阻塞极少数情况比如控制台应用的 Main 方法C# 7.1 之前不支持 async Main或者某些无法改造为异步的遗留代码。即便如此更好的做法是使用 await 并让调用链一直异步到入口点。2. async 关键字的作用async 关键字本身不创建异步它只做两件事允许在方法内使用 await没有 async 就不能用 await。强制编译器将该方法转换为状态机并将返回值包装为 Task/Task。所以 async 更像是一个“标记”告诉编译器这个方法体内有异步操作请帮我生成状态机代码。避免“异步 void”public async void Start() → 异常无法捕获调用方无法等待public async Task Start()UI 事件处理程序可以 _ Start() 或改用 async void 但内部 try-catch3. 异步方法的返回类型返回类型适用场景说明Task没有返回值的异步操作类似 void但可被 await 和捕获异常Task有返回值的异步操作返回 T 类型的结果void仅限 UI 事件处理程序异步无返回值但调用方无法等待、无法捕获异常危险ValueTask / ValueTask高频调用、多数情况同步完成的场景减少堆内存分配但使用限制较多小Tips:大多数普通应用不需要 ValueTask使用 Task 更安全。4. 异常处理在 async 方法内部抛出异常publicasyncTaskintDivideAsync(inta,intb){if(b0)thrownewDivideByZeroException();returnawaitTask.FromResult(a/b);}调用者用 try/catch 包裹 await 即可捕获异常try{intresultawaitDivideAsync(10,0);}catch(DivideByZeroExceptionex){// 捕获成功}关键点异常在 await 处传播而不是在调用 DivideAsync 时。因为 DivideAsync 返回的 Task 进入 Faulted 状态await 检测到后会重新抛出异常。5. async/await 与同步上下文的交互SynchronizationContext 决定 await 后代码跑在哪个线程UI 线程WPF/WinFormsawait 后自动回到 UI 线程 → 可直接更新控件类库 / 后台服务建议使用 ConfigureAwait(false) 避免不必要的上下文切换vardataawaitFile.ReadAllTextAsync(path).ConfigureAwait(false);6. await使用场景场景说明典型API网络请求从远程 API 获取数据如 REST 调用、下载文件。HttpClient.GetStringAsync / PostAsync文件 I/O读写大文件避免阻塞 UI 或线程池。File.ReadAllTextAsync / WriteAsync数据库操作查询、插入、更新数据尤其是 ORM 异步方法。SqlCommand.ExecuteReaderAsyncDbContext.SaveChangesAsync延迟或定时模拟等待或实现超时。Task.Delay异步流处理使用 IAsyncEnumerable 逐条消费数据。await foreach并行任务组合同时等待多个异步操作完成。Task.WhenAll / WhenAny跨服务调用微服务间 HTTP/gRPC 调用。GrpcClient.XXXAsync消息队列消费异步接收和处理消息如 RabbitMQ、Kafka 的异步客户端。BasicConsumeAsync三、CancellationToken 取消异步任务CancellationToken 其实就是一张“可以随时喊停”的凭证。就好比我们的小票在饭还没开始做的时候可以喊停。任务在合适的地方取消请求并退出CancellationToken 的基本用法角色组件作用遥控器CancellationTokenSource产生令牌并控制取消信号线CancellationToken传递给异步方法供其监听检测开关ThrowIfCancellationRequested()检测到取消时抛出 OperationCanceledException检测开关IsCancellationRequested非侵入式检查可自己退出循环1. 创建一个CancellationToken 取消程序//创建“遥控器”和“信号线”// 1. 创建一个遥控器CancellationTokenSourcectsnewCancellationTokenSource();// 2. 把信号线交给任务CancellationTokentokencts.Token;//写一个可以取消的任务Task.Run((){for(inti0;i100;i){// 每次循环都看一眼有人按取消了吗if(token.IsCancellationRequested){Console.WriteLine(收到取消信号退出);return;}// 否则继续干活Thread.Sleep(100);}},token);// 把 token 传给 Task.Run让它可以响应取消// 用户点了取消按钮cts.Cancel();另一种更“暴力”的写法Task.Run((){for(inti0;i100;i){// 如果取消了直接抛异常会被 Task 捕获任务状态变成 Canceledtoken.ThrowIfCancellationRequested();// 干活...}},token);两者区别IsCancellationRequested 是你自己判断、自己退出可以做一些清理工作再 return。ThrowIfCancellationRequested 是直接抛异常让上层 catch 处理适合不想写一堆 if 的情况。2. 带超时的取消// 方法1使用 CancelAfterCancellationTokenSourcectsnewCancellationTokenSource();cts.CancelAfter(200);// 200ms 后自动取消// 方法2直接传超时时间awaitsomeTask.WaitAsync(TimeSpan.FromMilliseconds(200));3. 多个取消信号合并需要同时响应“用户取消”和“超时自动取消”。可以用 CreateLinkedTokenSource 把两个信号合并。varuserCtsnewCancellationTokenSource();// 用户手动取消vartimeoutCtsnewCancellationTokenSource(5000);// 5秒超时// 把两个遥控器的信号合并成一个usingvarlinkedCtsCancellationTokenSource.CreateLinkedTokenSource(userCts.Token,timeoutCts.Token);vartokenlinkedCts.Token;// 把这个 token 传给任务无论是用户点取消还是超时任务都会收到取消信号awaitLongRunningTaskAsync(token);4. 总结我想做什么写什么代码创建遥控器var cts new CancellationTokenSource();取出信号线var token cts.Token;把信号线交给任务Task.Run(action, token) 或 await xxxAsync(token)任务内部检查if (token.IsCancellationRequested) break;任务内部抛异常token.ThrowIfCancellationRequested();触发取消 cts.Cancel();自动取消超时cts.CancelAfter(1000);用完释放cts.Dispose(); 或 using var cts new …合并多个信号CancellationTokenSource.CreateLinkedTokenSource(t1, t2)练习样例控制台程序异步下载 10 张图片支持中途取消usingSystem;usingSystem.Collections.Generic;usingSystem.IO;usingSystem.Net.Http;usingSystem.Threading;usingSystem.Threading.Tasks;//控制台程序异步下载 10 张图片支持中途取消namespaceConsole_program_Task_async_await{classProgram{// 图片URL列表Lorem Picsum 提供的随机图片privatestaticreadonlyListstringImageUrlsnewListstring{https://picsum.photos/id/1/200/300,https://picsum.photos/id/2/200/300,https://picsum.photos/id/3/200/300,https://picsum.photos/id/4/200/300,https://picsum.photos/id/5/200/300,https://picsum.photos/id/6/200/300,https://picsum.photos/id/7/200/300,https://picsum.photos/id/8/200/300,https://picsum.photos/id/9/200/300,https://picsum.photos/id/10/200/300};// 复用 HttpClientprivatestaticreadonlyHttpClienthttpClientnewHttpClient();staticasyncTaskMain(string[]args){Console.WriteLine(开始下载10张图片...);Console.WriteLine(提示按 C 键或按 CtrlC 可中途取消下载。\n);// 创建 CancellationTokenSource 用于取消操作using(varctsnewCancellationTokenSource()){// 注册 Ctrl C 事件实现取消Console.CancelKeyPress(sender,e){Console.WriteLine(\n检测到 CtrlC正在取消下载...);e.Canceltrue;// 阻止进程立即终止cts.Cancel();// 触发取消令牌};// 创建一个任务来监听键盘按键按 C 键取消varkeyListenerTaskTask.Run((){while(!cts.Token.IsCancellationRequested){if(Console.KeyAvailable){if(Console.KeyAvailablechar.ToUpper(Console.ReadKey(true).KeyChar)C){Console.WriteLine(\n用户按下了 C 键正在取消下载...);cts.Cancel();break;}Thread.Sleep(100);}}});// 创建下载目录stringdownloadPathPath.Combine(Directory.GetCurrentDirectory(),DownloadedImages);Directory.CreateDirectory(downloadPath);try{//开始下载所有图片awaitDownloadAllImagesAsync(ImageUrls,downloadPath,cts.Token);Console.WriteLine(\n所有图片下载完成);}catch(OperationCanceledException){Console.WriteLine(\n下载已被用户取消。);}catch(Exceptionex){Console.WriteLine($\n下载过程中发生错误:{ex.Message});}finally{// 确保键盘监听任务结束cts.Cancel();awaitkeyListenerTask;}// cts.Dispose() 自动调用}Console.WriteLine(按任意键退出...);Console.ReadKey();}privatestaticasyncTaskDownloadAllImagesAsync(Liststringurls,stringdownloadPath,CancellationTokencancellationToken){vardownloadTasksnewListTask();intindex1;foreach(stringurlinurls){stringfilePathPath.Combine(downloadPath,$image_{index}.jpg);downloadTasks.Add(DownloadImageAsync(url,filePath,index,cancellationToken));}awaitTask.WhenAll(downloadTasks);}// 下载单张图片并保存到本地privatestaticasyncTaskDownloadImageAsync(stringurl,stringfilePath,intimageIndex,CancellationTokencancellationToken){try{Console.WriteLine($[任务{imageIndex}] 开始下载{url});using(HttpResponseMessageresponseawaithttpClient.GetAsync(url,cancellationToken)){response.EnsureSuccessStatusCode();// 确保请求成功byte[]imageBytesawaitresponse.Content.ReadAsByteArrayAsync();// 异步写入文件支持取消using(varfileStreamnewFileStream(filePath,FileMode.Create,FileAccess.Write,FileShare.None,4096,useAsync:true)){awaitfileStream.WriteAsync(imageBytes,0,imageBytes.Length,cancellationToken);}}Console.WriteLine($[任务{imageIndex}] 下载完成并保存至{filePath});}catch(OperationCanceledException){Console.WriteLine($[任务{imageIndex}] 下载已取消。);throw;}catch(Exceptionex){Console.WriteLine($[任务{imageIndex}] 下载失败{ex.Message});throw;}}}}本文参考C# 官方文档https://learn.microsoft.com/en-us/dotnet/standard/parallel-programming/how-to-create-pre-computed-tasks博客园 https://www.cnblogs.com/yilezhu/p/10555849.htmlDeepseek https://chat.deepseek.com/