C#——多线程之Task

news/2024/5/17 19:28:29

C#——多线程之Task

  • 前言
  • 一、Task是什么?
  • 二、各应用场景以及实例分析
    • 1.异步执行代码
    • 2.等待异步操作完成
    • 3.并行执行多个任务
    • 4.处理异常
    • 5.取消异步操作
  • 三、一些其他问题
    • 1.WhenAll与WhenAny的区别
  • 总结


前言

在代码编写过程中,经常会用到多线程的知识,实现方法有很多种,突然想总结并理清楚其中的相关性与差异性。故以此开篇总结各种工具的用法与注意事项。本篇将对Task稍作总结。


一、Task是什么?

Task 是 .NET 中用于表示异步操作的类,它提供了一种简单和强大的方式来处理异步编程。Task 可以用于各种应用场景和功能,包括:

  1. 异步执行代码:Task 允许在单独的线程上执行代码块,从而避免阻塞主线程,提高程序的响应性和并发性。
  2. 等待异步操作完成:通过 await 关键字可以等待 Task 完成,从而实现非阻塞的异步操作。
  3. 并行执行多个任务:Task 可以用于并行执行多个独立的任务,从而加快任务的完成速度,提高系统的性能。
  4. 处理异常:Task 提供了异常处理机制,可以在异步操作中捕获和处理异常。
  5. 轻量级的线程管理:Task 使用线程池来管理线程,避免了频繁创建和销毁线程的开销,使得线程的管理更加高效。
  6. 取消异步操作:Task 支持取消操作,可以通过 CancellationToken 来取消正在进行的异步操作。

总的来说,Task 是一种非常有用的工具,它在异步编程中起着至关重要的作用,可以帮助开发人员编写高效、响应式和可靠的异步代码。

二、各应用场景以及实例分析

1.异步执行代码

假设我们需要在后台线程中执行一个耗时的操作,而不阻塞主线程。使用 Task 可以很方便地实现这一点。例如,我们可以使用 Task.Run 方法在后台线程中执行一个计算操作,然后在主线程中继续执行其他代码:

代码如下(示例):

        static void Main(string[] args){Task.Run(() =>{Console.WriteLine("task");Task.Delay(2000).Wait(); //模拟耗时操作Console.WriteLine("taskEnd");});Task.Delay(1000).Wait();Console.WriteLine($"main");Console.ReadKey();}

结果如下图:
在这里插入图片描述

2.等待异步操作完成

使用 await 关键字可以等待 Task 完成,从而实现非阻塞的异步操作。例如,在 Windows Forms 或 WPF 应用程序中,我们可以在异步方法中使用 await 来等待异步操作完成后更新 UI:

        public static async Task wait(){await Task.Delay(2000); //将等待2秒后,继续执行下面的代码Console.WriteLine("Wait 2000 ms");}

3.并行执行多个任务

假设我们有多个独立的任务,可以使用 Task.WhenAll 方法来等待它们执行完成。
代码如下(示例):

        static async Task test(){Task[] tasks = new Task[3];tasks[0] = wait();tasks[1] = wait2();tasks[2] = wait3();await Task.WhenAll(tasks);Console.WriteLine("main");Console.ReadKey();}public static async Task wait(){await Task.Delay(2000);Console.WriteLine("Wait 2000 ms");}public static async Task wait2(){await Task.Delay(3000);Console.WriteLine("Wait 3000 ms");}public static async Task wait3(){await Task.Delay(4000);Console.WriteLine("Wait 4000 ms");}

结果如下图:
在这里插入图片描述

ps:
上述代码有个小细节:在 test() 方法中,没有显式地调用 Start() 方法,因为在使用 async/await 时不需要手动启动任务。async 方法本身会确保异步方法在调用时会自动启动,所以不需要手动调用 Start()。

遇到点小问题:
我在通过入下代码,new task进行新建,start进行启动时,出现Main在wait 。。前先被打印出来如下:

        static async Task test(){Task[] tasks = new Task[3]{new Task( ()=>  wait()),new Task( ()=>  wait2()),new Task( ()=>  wait3())};foreach (var item in tasks){item.Start();}await Task.WhenAll(tasks);Console.WriteLine("main");Console.ReadKey();}

在这里插入图片描述

Task.WhenAll() 方法只能等待当前线程池中的任务完成。如果任务没有被调度到线程池上运行,那么 Task.WhenAll() 方法将无法等待这些任务完成。
当你使用 Task.Run() 或 Task.Factory.StartNew() 方法创建任务时,这些任务会被自动调度到线程池上运行,因此 Task.WhenAll() 方法可以等待它们的完成。
而通过 new Task() 创建任务对象后,手动调用 Start() 方法来启动任务,但这些任务并没有被自动调度到线程池上运行。因此,Task.WhenAll() 方法无法等待这些任务完成。

4.处理异常

Task 提供了异常处理机制,可以在异步操作中捕获和处理异常。例如,我们可以使用 try-catch 块来处理异步操作中可能抛出的异常:

        static void Main(string[] args){test();Console.WriteLine("main");Console.ReadKey();}static async void test(){try{await wait();}catch (Exception){Console.WriteLine("报错啦!");}}public static async Task wait(){await Task.Delay(2000);Console.WriteLine("Wait 2000 ms");throw new Exception("wwww");}

结果如下:
在这里插入图片描述

ps:此处需要注意的是try/catch在await上下文时才能生效,否则无法捕获到异常。

5.取消异步操作

Task 支持取消操作,可以通过 CancellationToken 来取消正在进行的异步操作。例如,我们可以在异步方法中检查 CancellationToken 的状态,并在需要时取消操作:

        static void Main(string[] args){CancellationTokenSource cancellationTokenSource = new CancellationTokenSource();CancellationToken cancellationToken = cancellationTokenSource.Token;Task.Run(async () =>{try{int i = 0;while (!cancellationToken.IsCancellationRequested){await Task.Delay(1000);Console.WriteLine($"第{i}次等待");i += 1;}cancellationToken.ThrowIfCancellationRequested();//可弹出OperationCanceledException类型的错误}catch (OperationCanceledException){Console.WriteLine($"任务被取消");}}, cancellationToken);Thread.Sleep(5000);cancellationTokenSource.Cancel();//取消任务Console.ReadKey();}

结果如下图:
在这里插入图片描述

ps:其实通过一个全局布尔变量也可以达到上面中止任务的效果,但cancellationToken中封装了一些取消任务后的回调,减少了自己码代码的时间,但增加了学习理解的成本。

三、一些其他问题

1.WhenAll与WhenAny的区别

WhenAll:是要等待所以的任务完成才返回;如上文并行任务章节内容。
WhenAny:只要一个任务完成,就立马结束等待。如下。

        static async Task test(){Task[] tasks = new Task[3];tasks[0] = wait();tasks[1] = wait2();tasks[2] = wait3();await Task.WhenAny(tasks);Console.WriteLine("main");Console.ReadKey();}

在这里插入图片描述


总结

上文我们通过各实例内容,粗略了解了Task的各种应用,在使用中还会遇见多种问题,在此无法详尽的列举出来。在以后的过程中,如果遇见问题的话我会陆续更新到这里,希望本文对大家有所帮助。下次我们将继续了解多线程中的Thread。我们下次再见。


http://www.mrgr.cn/p/62820081

相关文章

三子棋(超详解+完整码源)

三子棋 前言一,游戏规则二,所需文件三,创建菜单四,游戏核心内容实现1.棋盘初始化1.棋盘展示3.玩家下棋4.电脑下棋5.游戏胜负判断6.game()函数内部具体实现 四,游戏运行实操 前言 C语言实现三子棋…

volley 学习笔记1--发送请求

一、概览 Volley 具有以下优势: 自动网络请求调度。 多个并发网络连接。 透明磁盘和具有标准 HTTP 缓存一致性的内存响应缓存。 支持请求优先级。 取消请求 API。您可以取消单个请求,也可以设置要取消的请求的时间段或范围。 可轻松自定义&#xff…

手机快充协议

高通:QC2.0、QC3.0、QC3.5、QC4.0、QC5.0、 FCP、SCP、AFC、SFCP、 MTKPE1.1/PE2.0/PE3.0、TYPEC、PD2.0、PD3.0/3.1、VOOC 支持 PD3.0/PD2.0 支持 QC3.0/QC2.0 支持 AFC 支持 FCP 支持 PE2.0/PE1.1 联发科的PE(Pump Express)/PE 支持 SFCP 在PP…

Stable Diffusion如何生成高质量的图-prompt写法介绍

文章目录 Stable Diffusion使用尝试下效果prompt的编写技巧prompt 和 negative promptPrompt格式Prompt规则细节优化Guidance Scale 总结 Stable Diffusion Stable Diffusion是一个开源的图像生成AI系统,由Anthropic公司开发。它基于 Transformer模型架构,可以通过文字描述生成…

学习笔记|大模型优质Prompt开发与应用课(二)|第五节:只需3步,优质Prompt秒变应用软件

原作者:依依│百度飞桨产品经理 一乔│飞桨开发者技术专家 分享内容 01:大模型应用简介 02:LLM应用开发范式 03: Al Studio大模型社区 04:AI对话类应用开发技巧 大模型技术爆发,各类应用产品涌现 文心产业级知识增强大模型 工作中的“超级助手”—…

一文谈谈Git

"And if forever lasts till now Alright" 为什么要有git? 想象一下,现如今你的老师同时叫你和张三,各自写一份下半年的学习计划交给他。 可是你的老师是一个极其"较真"的人,发现你俩写的学习计划太"水&…

MySQL5.7 与 MariaDB10.1 审计插件兼容性验证

这是一篇关于发现 MariaDB 审计插件导致 MySQL 发生 crash 后,展开适配验证并进行故障处理的文章。 作者:官永强 爱可生DBA 团队成员,擅长 MySQL 运维方面的技能。热爱学习新知识,亦是个爱打游戏的宅男。 本文来源:原创…

简单认识redis高可用实现方法

文章目录 一、redis群集三种模式二、 Redis 主从复制1、简介2、作用:3、流程:4.配置主从复制 三、Redis 哨兵模式1、简介2、原理:3、作用:4、哨兵结构由两部分组成,哨兵节点和数据节点:5、故障转移机制:6、…

软件外包开发的后台开发语言

在软件外包开发中,后台语言的选择通常取决于项目需求、客户偏好、团队技能和开发效率。今天和大家分享一些常用的后台语言及选择它们的原因,希望对大家有所帮助。北京木奇移动技术有限公司,专业的软件外包开发公司,欢迎交流合作。…

【利诱和强制分享下载】规则修改指引

代码审核环节,将会对小程序运营的内容进行核实是否存在阻断功能,损害用户体验。 常见利诱诱导类型: 1、利诱下载APP 小程序内出现不断弹窗、频繁提示诱导用户下载APP,强制用户必须下载APP才能体验完整功能服务。 示例&#xf…

数字化时代,如何做好用户体验与应用性能管理

引言 随着数字化时代的到来,各个行业的应用系统从传统私有化部署逐渐转向公有云、行业云、微服务,这种变迁给运维部门和应用部门均带来了较大的挑战。基于当前企业 IT 运维均为多部门负责,且使用多种运维工具,因此,当…

【Spring】Spring 中事务的实现

事务定义:将⼀组操作封装成⼀个执⾏单元(封装到⼀起),要么全部成功,要么全部失败 Spring 中的事务操作分为两类: 编程式事务(⼿动写代码操作事务)。声明式事务(利⽤注解…

【hive】Install hive using mysql as hive metadata service

文章目录 一. Requirements二. Installing Hive from a Stable Release三. Running Hive四. Running Hive CLI五.Running HiveServer2 and Beeline1. 下载安装mysql2. 下载mysql驱动3. 配置hive-site.xml4. 初始化元数据库5. 通过beeline进行连接 一. Requirements Users are s…

php 生成连续递增的Excel列索引 可以控制多少列

今天遇到需要生成对应的下拉&#xff0c;下拉的类 需要PHP 输出一个数组 如 A、B、C、D 到Z 列后 Excel 的列就变成 AA 、AB、 AC 依次类推 查询得知 Excel 最大列数 16384 最大行数 1048576 下面演示3000列或行 <?php$idx [idx > 0];for ($i …

OpenCV4.3 Java 编程入门:透明度与抠图

1. 基础知识 JPG 格式图片有损压缩和不支持半透明&#xff0c;如果想在图片上添加透明通道&#xff0c;一定不要用 JPG 格式的图片&#xff1b;PNG&#xff1a;既支持3通道RGB图像&#xff0c;也支持4通道RGBA图像&#xff08;红色、绿色、蓝色和透明度&#xff09;&#xff1…

NOSQL之Redis配置及优化

目录 一、关系型数据库 二、非关系型数据库 三、关系型数据库和非关系型数据库区别 1、数据存储方式不同 2、扩展方式不同 3、对事务性的支持不同 四、Redis简介 五、Redis优点 &#xff08;1&#xff09;具有极高的数据读写速度 &#xff08;2&#xff09;支持丰富的…

AI 绘画Stable Diffusion 研究(一)sd整合包v4.2 版本安装说明

部署包作者:秋葉aaaki 免责声明: 本安装包及启动器免费提供 无任何盈利目的 大家好&#xff0c;我是风雨无阻。众所周知&#xff0c;StableDiffusion 是非常强大的AI绘图工具&#xff0c;需要详细了解StableDiffusion的朋友&#xff0c;可查看我之前的这篇文章&#xff1a; 最…

9条建议告诉你如何正确处理PCB设计布线

一、关于PCB布线线宽 1、布线首先应满足工厂加工能力&#xff0c;首先向客户确认生产厂家&#xff0c;确认其生产能力&#xff0c;如图1所示。如客户无要求&#xff0c;线宽参考阻抗设计模板。 图1 PCB板厂线宽要求 2、阻抗模板&#xff0c;根据客户提供的板厚及层数要求&…

页面生成图片或PDF node-egg

没有特别的幸运&#xff0c;那么就特别的努力&#xff01;&#xff01;&#xff01; 中间件&#xff1a;页面生成图片 node-egg 涉及到技术node egg Puppeteer 解决文书智能生成多样化先看效果环境准备初始化项目 目录结构核心代码 完整代码https://gitee.com/hammer1010_ad…

[论文笔记] CLRerNet: Improving Confidence of Lane Detection with LaneIoU

Honda, Hiroto, and Yusuke Uchida. “CLRerNet: Improving Confidence of Lane Detection with LaneIoU.” arXiv preprint arXiv:2305.08366 (2023). 2023.05 出的一篇车道线检测的文章, 效果在CULane, CurveLanes SOTA 文章目录 简介LaneIoULineIoU存在问题为什么使用LaneIo…