C#——多线程之Task

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.mfbz.cn/a/49800.html

如若内容造成侵权/违法违规/事实不符,请联系我们进行投诉反馈qq邮箱809451989@qq.com,一经查实,立即删除!

相关文章

初步了解C++模板

一、函数模板 如果我们要写一个交换两个变量值的函数Swap&#xff0c;那么我们得对每一种类型都写一个&#xff0c;以便适用不同类型的参数&#xff0c;但是有了模板之后&#xff0c;可以简化操作 template<class T> void Swap(T& x, T& y) {T tmp x;x y;y …

第J2周:ResNet50V2算法实战与解析

&#x1f368; 本文为&#x1f517;365天深度学习训练营 中的学习记录博客&#x1f366; 参考文章&#xff1a;365天深度学习训练营-第J2周&#xff1a;ResNet50V2算法实战与解析&#x1f356; 原作者&#xff1a;K同学啊|接辅导、项目定制 目录 一、论文解读1. ResNetV2结构与…

Linux下查找python路径

本地目前装了几个版本的python&#xff0c;这里记录下查找python路径的方法。 1&#xff1a;whereis命令 whereis python2&#xff1a;which命令 which python与whereis相似&#xff0c;但which会返回第一个找到的执行文件的位置。 3&#xff1a;find命令 find命令可以搜索系…

CenOS设置启动级别

背景知识 init一共分为7个级别&#xff0c;这7个级别的所代表的含义如下 0&#xff1a;停机或者关机&#xff08;千万不能将initdefault设置为0&#xff09;1&#xff1a;单用户模式&#xff0c;只root用户进行维护2&#xff1a;多用户模式&#xff0c;不能使用NFS(Net File S…

【Docker】Docker相关基础命令

目录 一、Docker服务相关命令 1、启动docker服务 2、停止docker服务 3、重启docker服务 4、查看docker服务状态 5、开机自启动docker服务 二、Images镜像相关命令 1、查看镜像 2、拉取镜像 3、搜索镜像 4、删除镜像 三、Container容器相关命令 1、创建容器 2、查…

【C++】开源:Linux端ALSA音频处理库

&#x1f60f;★,:.☆(&#xffe3;▽&#xffe3;)/$:.★ &#x1f60f; 这篇文章主要介绍Linux端ALSA音频处理库。 无专精则不能成&#xff0c;无涉猎则不能通。。——梁启超 欢迎来到我的博客&#xff0c;一起学习&#xff0c;共同进步。 喜欢的朋友可以关注一下&#xff0c…

Windows数据类型LPSTR学习

Windows在C语言的基础之上又定义了一些Windows下的数据类型&#xff1b;下面学习一下LPSTR&#xff1b; LPSTR和LPWSTR是Win32和VC所使用的一种字符串数据类型。LPSTR被定义成是一个指向以NULL(‘\0’)结尾的32位ANSI字符数组指针&#xff0c;而LPWSTR是一个指向以NULL结尾的64…

代码版本管理工具 git

1. 去B站看视频学习&#xff0c;只看前39集&#xff1a; 01-Git概述&#xff08;Git历史&#xff09;_哔哩哔哩_bilibili 2.学习Linux系统文本编辑器的使用 vi编辑器操作指令分享 (baidu.com) (13条消息) nano编辑器的使用_SudekiMing的博客-CSDN博客 windows下载安装Git官…

电路原理分析1

d2的作用是提供一个1.25v的电平 r3、r4的作用都是限流 c1是滤波 运放的4、8脚是常规的外围 这个运放是一个运算放大电路 具体计算是这样的&#xff1a; 按照虚短原则&#xff0c;输入的信号Uinu1,输出的信号Uoutu3 按照虚断原则&#xff0c;i1i2i5i5 u1/r2i1i5&#xff…

Longhorn vs Rook vs OpenEBS vs Portworx vs IOMesh:细说 5 款 K8s 持久化存储产品优劣势

云原生时代下&#xff0c;越来越多的企业开始使用 Kubernetes&#xff08;K8s&#xff09;承载数据库、消息中间件等“生产级”有状态工作负载。由于这些应用对数据持久保存、性能、容量扩展和快速交付具有较高的要求&#xff0c;企业往往需要采用专为 Kubernetes 环境设计的持…

wxwidgets Ribbon使用简单实例

// RibbonSample.cpp : 定义控制台应用程序的入口点。 // #include "stdafx.h" #include <wx/wx.h> #include "wx/wxprec.h" #include "wx/app.h" #include "wx/frame.h" #include "wx/textctrl.h" #include "…

教雅川学缠论02-K线

传统行情上的K线是下图中这样子的 而在缠论中K线是下面这样子的&#xff0c;它没有上影线和下影线 下图是武汉控股2023年7月的日K线 接下来我们将它转换成缠论K线&#xff08;画图累死我了&#xff09; K线理解了我们才能进行下一步&#xff0c;目前位置应该很好理解的

压缩算法的原理丨基因型vcf文件为什么压缩后发生了什么?

压缩算法的本质 最近碰到一个神奇的现象&#xff0c;一份大小为16GB的xx.vcf.gz文件&#xff0c;解压之后体积变为600GB的vcf文件&#xff0c;为什么一份文件经过压缩后体积缩小了这么多&#xff1f; (work) [bio notes 21:29:40 ~/work/20230726/data]$ ls -lh总用量 620GB-…

OnnxRuntime TensorRT OpenCV::DNN性能对比(YoloV8)实测

1. 前言 之前把ORT的一套推理环境框架搭好了,在项目中也运行得非常愉快,实现了cpu/gpu,fp32/fp16的推理运算,同onnx通用模型在不同推理框架下的性能差异对比贴一下,记录一下自己对各种推理框架的学习状况 YoloV8模型大小 模型名称参数量NANO3.2M...... 2. CPU篇 CPU推理框架性…

机器人状态估计:robot_localization 功能包高级参数详解

机器人状态估计&#xff1a;robot_localization 功能包高级参数详解 前言功能包简介相关参数高级参数 前言 移动机器人的状态估计需要用到很多传感器&#xff0c;因为对单一的传感器来讲&#xff0c;都存在各自的优缺点&#xff0c;所以需要一种多传感器融合技术&#xff0c;将…

扫地机语音提示芯片,智能家居语音交互首选方案,WT588F02B-8S

智能家居已经成为现代家庭不可或缺的一部分&#xff0c;而语音交互技术正是智能家居的核心。在智能家居设备中&#xff0c;扫地机无疑是最受欢迎的产品之一。然而&#xff0c;要实现一个更智能的扫地机&#xff0c;需要一颗语音提示芯片&#xff0c;以提供高质量的语音交互体验…

【MySQL】表的内外连接

目录 一、内连接二、外连接2.1 左外连接2.2 右外连接 三、OJ题 表的连接分为内连和外连 一、内连接 内连接实际上就是利用where子句对两种表形成的笛卡儿积进行筛选&#xff0c;我们前面学习的查询都是内连接&#xff0c;也是在开发过程中使用的最多的连接查询。 语法&#x…

Feign API模块导入的两种方式

说明&#xff1a;在微服务框架中&#xff0c;会把其他微服务用到的FeignClient统一放到一个模块里面&#xff0c;称为FeignAPI&#xff0c;其他微服务需要使用FeignClient&#xff0c;可以引入FeignAPI的Maven坐标。 但是只引入FeignAPI的坐标还不行&#xff0c;FeignAPI中的B…

自动化测试:让软件测试更高效更愉快!

谈谈那些实习测试工程师应该掌握的基础知识&#xff08;一&#xff09;_什么时候才能变强的博客-CSDN博客https://blog.csdn.net/qq_17496235/article/details/131839453谈谈那些实习测试工程师应该掌握的基础知识&#xff08;二&#xff09;_什么时候才能变强的博客-CSDN博客h…

STM32CubeMX v6.9.0 BUG:FLASH_LATENCY设置错误导致初始化失败

背景 今天在调试外设功能时&#xff0c;发现设置了使用外部时钟之后程序运行异常&#xff0c;进行追踪调试并与先前可以正常运行的项目进行对比之后发现这个问题可能是由于新版本的STM32CubeMX配置生成代码时的BUG引起的。 测试环境 MCU: STM32H750VBT6 STM32CubeIDE: Versi…