【.NET Core】Task应用详解

【.NET Core】Task应用详解

文章目录

  • 【.NET Core】Task应用详解
    • 一、概述
    • 二、Task用法应用
      • 2.1 通过New实例化Task
      • 2.2 通过Factory中StartNew方法
      • 2.3 通过Run方法
    • 三、让Task任务按顺序执行
    • 四、通过异步Run方法异步执行顺序Task
    • 五、创建带有返回值的Task<TResult>
    • 六、Task常用的属性与方法
    • 七、Task总结
    • 七、参考资料

一、概述

Task(任务)是一个类似于Thead(线程)或ThreadPool(线程池)概念是一个异步执行的工具类。它是一个更轻的类线程工具。Task提供简化编写并发和异步代码的工具类。它包含的类型为TaskTask<TResult>TaskFactory类提供用于创建和启动Task任务的静态方法。TaskScheduler类提供默认线程调度基础结构。

Task表示不返回值且通常异步执行的单个操作。Task对象是.NET Framework4中首次引入的基于任务的异步模式的核心组件之一。由于对象执行Task的工作通常在线程池线程上异步执行,而不是在main应用程序线程上同步执行,因此可以使用Statu属性以及IsCanceled、IsCompleted和IsFaulted属性来确定任务的状态。

二、Task用法应用

Task基本使用可以通过New实例化一个Task的应用,也使用通过StartNew来使用Task,还有一种是通过Run使用Task。下面实例通过代码演示三种Task基本的应用。

2.1 通过New实例化Task

Task task1=new Task(()=>{Thread.Sleep(1000);Debug.WriteLine("执行第一个Task任务.") 
});
Debug.WriteLine($"Task ID"+task1.id)

输出结果:

线程 0x6704 已退出,返回值为 0 (0x0)。
第一个任务ID13
执行第一个Task任务

2.2 通过Factory中StartNew方法

Task task2=new Task(()=>{Thread.Sleep(1500);Debug.WriteLine("执行第二个Task任务.") 
});
Debug.WriteLine($"Task2 ID"+task2.id);

2.3 通过Run方法

Task task3=new Task(()=>{Thread.Sleep(2000);Debug.WriteLine("执行第三个Task任务.");
})
Debug.WriteLine($"Task3 ID"+task3.id);

上面三种方法都可以创建一个Task应用。

类Task提供的异常三种创建任务和执行任务的方法。出于性能原因,Task.Run或TaskFactory.StartNew方法是创建和计划计算任务的首选机制,但对于必须分离创建和计划的方案,才考虑使用Task.Start方法计划任务以供以后执行。

三、让Task任务按顺序执行

Task task1 = new Task(() => { Thread.Sleep(1000);Debug.WriteLine("执行第一个Task任务");
});
Task task2 = new Task(() => {Thread.Sleep(5000);Debug.WriteLine("执行第二个Task任务");
});
Task task3 = new Task(() => {Thread.Sleep(2000);Debug.WriteLine("执行第三个Task任务");
});
Task task4 = new Task(() => {Thread.Sleep(1000);Debug.WriteLine("执行第四个Task任务");
});IList<Task> tasks= new List<Task>();
tasks.Add(task1);
tasks.Add(task2);
tasks.Add(task3);
tasks.Add(task4);
foreach (var task in tasks) {task.Start();task.Wait();
}

如果想要Task按顺序执行,需要给Task加上Wait方法,然后让其阻塞等待完成后在执行下一个Task任务。

四、通过异步Run方法异步执行顺序Task

 public async void RunTask() {await Task.Run(async () =>{await Task.Delay(1000);Debug.WriteLine("第1个线程执行");});await Task.Run(async () =>{await Task.Delay(8000);Debug.WriteLine("第2个线程执行");});await Task.Run(async () =>{await Task.Delay(2000);Debug.WriteLine("第3个线程执行");});await Task.Run(async () =>{await Task.Delay(3000);Debug.WriteLine("第4个线程执行");});
}

通过异步await 和async通过 Task.Run创建按次序的Task任务。

五、创建带有返回值的Task

Task和Task暴露静态的Factory属性,该属性返回一个默认的TaskFactory实例,以便调用Task.Factory.StartNew()方法。Task和Taste有一个属性Result属性,该属性包含了运算的结果。任务是异步运行的,可能以任意时序执行完。若Result属性在运行结束前被访问,这个属性会阻塞调用线程到该值可访问。

public async void RunTask() 
{Task<Double>[] taskArray = { Task<Double>.Factory.StartNew(() => DoComputation(10.0)),Task<Double>.Factory.StartNew(() => DoComputation(100.0)),Task<Double>.Factory.StartNew(() => DoComputation(1000.0)) };foreach (var task in taskArray){double result = task.Result;Debug.WriteLine(result);}
}

六、Task常用的属性与方法

6.1 AsyncStates属性

获取在创建Task时提供的状态对象,如果未提供,则为null。

6.2 CompletedTask属性

获取一个已成功的任务

6.2 CurrentId属性

返回当前正在执行Task的ID

6.3 Factory属性

提供对用于创建和配置Task和Task实例的工厂方法的访问

6.4 Id属性

获取此Task实例的ID

6.5 IsCanceled属性

获取此Task实例是否由于被取消的原因而完成执行

6.6 IsCompleted属性

获取一个值,它表示是否已完成任务

6.7 IsCompletedSuccessfully属性

了解任务是否运行到完成

6.7 IsFaulted属性

获取Task是否由于未经处理异常的原因而完成

6.8 Status属性

表示Task的生命周期中的当前阶段

  • 0 = Created 该任务已初始化,但尚未被计划

  • 1 = WaitingForActivation 该任务正在等待 .NET 基础结构在内部将其激活并进行计划。

  • 2 = WaitingToRun 该任务已被计划执行,但尚未开始执行

  • 3 = Running 该任务正在运行,但尚未完成

  • 4 = WaitingForChildrenToComplete 该任务已完成执行,正在隐式等待附加的子任务完成

  • 5 = RanToCompletion 已成功完成执行的任务

  • 6 = Canceled 该任务已通过对其自身的 CancellationToken 引发 OperationCanceledException 对取消进行了确认,此时该标记处于已发送信号状态;或者在该任务开始执行之前,已向该任务的 CancellationToken 发出了信号

  • 7 = Faulted 由于未处理异常的原因而完成的任务

6.9 ConfigureAwait(Boolean) 方法

配置用于等待此Task的awaiter

6.10 ContinueWith(Action<Task,Object>,Object,TaskScheduler) 方法

创建一个在目标Task完成时接收调用方提供的状态信息和取消标记并执行的延续任务。延续任务根据一组指定的条件执行,并使用指定的计划程序。

6.11 Delay(TimeSpan,CancellationToken) 方法

创建一个在指定的毫秒数后完成的可取消任务或创建一个指定的时间间隔后完成的可取消的任务。

6.12 Run(Action,CancellationToken) 方法

将在线程池上运行的指定工作排队,并返回代表该工作的 Task对象。 可使用取消标记来取消工作(如果尚未启动)。

6.13 Start(TaskScheduler) 方法

启动Task, 并将它安排到当前的TaskScheduler中执行

6.14 Wait(Task[],CancellationToken) 方法

等待提供的所有Task对象在指定的毫秒数内完成执行,或等到取消等待

6.15 Yield()方法

创建异步产生当前上下文的等待任务。

七、Task总结

Task是并行编程的一个重要的特性,主要的特点有一下几点:

  • 底层是在线程池中运作的,且微软用了一些增强性能的算法(这点使你在大部分场景中可以无忧地使用它)
  • 实际使用往往会结合lambda表达式
  • 结合lambda表达式在循环中使用计数器时,需要注意lambda内使用计数器是其引用。可以使用自定义传参给任务来回避这种情况

在实际的开发中还需要根据实际的应用场景,选项合适的属性和方法,希望你通过本文能完全掌握Task的应用。

七、参考资料

https://learn.microsoft.com/zh-cn/dotnet/standard/parallel-programming/task-parallel-library-tpl

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/168452.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

Spark SQL 时间格式处理

初始化Spark Sql package pbcp_2023.clear_dataimport org.apache.spark.SparkConf import org.apache.spark.sql.SparkSession import org.apache.spark.sql.functions.{current_date, current_timestamp}object twe_2 {def main(args: Array[String]): Unit {val con new …

认识Linux操作系统

什么是操作系统&#xff1f; 操作系统是一款软硬件资源管理的软件Linux是一款具体的操作系统的品类&#xff08;Linux内核是用C语言写的&#xff09;centos7是一款具体的Linux操作系统 为什么要有操作系统&#xff1f; Linux操作系统 Linux是一种自由和开放源代码的类UNIX操…

Linux时间命令—— 显示时间,日历等

目录 1.date显示时间 1.1 常用的标记列表&#xff1a; 1.2 设定时间&#xff1a; 2.cal显示日历 3.时间戳 1.date显示时间 date 用法&#xff1a;date [OPTION] ... [FORMAT] 1.1 常用的标记列表&#xff1a; %H : 小时 (00..23) %M : 分钟 (00..59) %S : 秒 (00..61…

基于Python的面向对象分类实例Ⅱ

接上一部分继续介绍~ 一、地类矢量转栅格 这一步是为了能让地类值和影像的对象落在同一区域&#xff0c;从而将影像中的分割对象同化为实际地物类别。 train_fn r".\train_data1.shp" train_ds ogr.Open(train_fn) lyr train_ds.GetLayer() driver gdal.GetDrive…

android BSP开发之五(Launcher 其他设定)

1.调整Home screen上Hotseat, Google folder , Play store.在开发过程中&#xff0c;如果要求更改Hotseat和Google folder中的某些APP, 或者这些APP在home screen中的位置&#xff0c;则可以在vendor/partner_gms/apps/GmsSampleIntegration/res_dhs_full/xml/partner_default_…

python之pyqt专栏3-QT Designer

从前面两篇文章python之pyqt专栏1-环境搭建与python之pyqt专栏2-项目文件解析&#xff0c;我们对QT Designer有基础的认识。 QT Designer用来创建UI界面&#xff0c;保存的文件是"xxx.ui"文件&#xff0c;"xxx.ui"可以被pyuic转换为"xxx.py",而&…

Spring AOP:什么是AOP? 为什么要用AOP?如何学习AOP?

文章目录 &#x1f386;前言1.为什么要用 AOP3.如何学习去 AOP?3.1 AOP 的组成切面&#xff08;Aspect&#xff09;连接点&#xff08;Join Point&#xff09;切点&#xff08;Pointcut&#xff09;通知&#xff08;Advice&#xff09; 3. Spring AOP 实现3.1 普通的方式实现 …

Ubuntu20.04安装搜狗输入法

1、安装包下载 搜狗输入法linux-首页搜狗输入法for linux—支持全拼、简拼、模糊音、云输入、皮肤、中英混输https://shurufa.sogou.com/linux点击立即下载&#xff0c;根据自己的硬件选择deb安装包。 2、输入法安装 当第一步完成以后&#xff0c;页面会自动跳转至搜狗的安装…

【opencv】计算机视觉:实时目标追踪

目录 前言 解析 深入探究 前言 目标追踪技术对于民生、社会的发展以及国家军事能力的壮大都具有重要的意义。它不仅仅可以应用到体育赛事当中目标的捕捉&#xff0c;还可以应用到交通上&#xff0c;比如实时监测车辆是否超速等&#xff01;对于国家的军事也具有一定的意义&a…

25 Linux I2C 驱动

一、I2C简介 I2C老朋友了&#xff0c;在单片机里面也学过&#xff0c;现在再复习一下。I2C使用两条线在主控制器和从机之间进行数据通信。一条是 SCL(串行时钟线)&#xff0c;另外一条是 SDA(串行数据线)&#xff0c;这两条数据线需要接上拉电阻&#xff0c;总线空闲的时候 SCL…

docker部署phpIPAM

0说明 IPAM&#xff1a;IP地址管理系统 IP地址管理(IPAM)是指的一种方法IP扫描&#xff0c;IP地址跟踪和管理与网络相关的信息的互联网协议地址空间和IPAM系统。 IPAM软件和IP的工具,管理员可以确保分配IP地址仍然是当前和足够的库存先进的IP工具和IPAM服务。 IPAM简化并自动化…

开源大模型框架llama.cpp使用C++ api开发入门

llama.cpp是一个C编写的轻量级开源类AIGC大模型框架&#xff0c;可以支持在消费级普通设备上本地部署运行大模型&#xff0c;以及作为依赖库集成的到应用程序中提供类GPT的功能。 以下基于llama.cpp的源码利用C api来开发实例demo演示加载本地模型文件并提供GPT文本生成。 项…

管理类联考——数学——汇总篇——知识点突破——代数——函数——记忆

文章目录 整体文字提炼图像绘画 考点记忆/考点汇总——按大纲 本篇思路&#xff1a;根据各方的资料&#xff0c;比如名师的资料&#xff0c;按大纲或者其他方式&#xff0c;收集/汇总考点&#xff0c;即需记忆点&#xff0c;在通过整体的记忆法&#xff0c;比如整体信息很多&am…

中国天然径流量格点数据集CNRD v1.0(1961-2018)

简介 中国天然径流量是指在中国境内自然形成的各种河流、湖泊、水库等水体中自然产生的流量。根据中国水利部的数据,中国天然径流量在年际变化和地区分布上都非常不均衡。北方地区径流量较小,南方地区则较大;而东部沿海地区的水资源较为丰富,而西北干旱地区的水资源则非常…

电源控制系统架构(PCSA)之系统控制处理器组件

目录 6.4 系统控制处理器 6.4.1 SCP组件 SCP处理器Core SCP处理器Core选择 SCP处理器核内存 系统计数器和通用计时器 看门狗 电压调节器控制 时钟控制 系统控制 信息接口 电源策略单元 传感器控制 外设访问 系统访问 6.4 系统控制处理器 系统控制处理器(SCP)是…

基于Python 中创建 Sentinel-2 RGB 合成图像

一、前言 下面的python代码将带您了解如何从原始 Sentinel-2 图像创建 RGB 合成图像的过程。 免费注册后&#xff0c;可以从 Open Access Hub 下载原始图像。 请注意&#xff0c;激活您的帐户可能需要 24 小时&#xff01; 二、准备工作 &#xff08;1&#xff09;导入必要的库…

selenium的基础语法

&#x1f4d1;打牌 &#xff1a; da pai ge的个人主页 &#x1f324;️个人专栏 &#xff1a; da pai ge的博客专栏 ☁️山水速疾来去易&#xff0c;襄樊镇固永难开 ☁️定位页面的元素 参数:抽象类By里…

springboot 开启和关闭kafka消费

关闭kafka自动消费 配置自定义容器工厂 import org.springframework.beans.factory.annotation.Autowired; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.kafka.config.C…

【从删库到跑路 | MySQL总结篇】数据库基础(增删改查的基本操作)

个人主页&#xff1a;兜里有颗棉花糖 欢迎 点赞&#x1f44d; 收藏✨ 留言✉ 加关注&#x1f493;本文由 兜里有颗棉花糖 原创 收录于专栏【MySQL学习专栏】&#x1f388; 本专栏旨在分享学习MySQL的一点学习心得&#xff0c;欢迎大家在评论区讨论&#x1f48c; 重点放前面&am…

Android frameworks 开发总结之八

Quick Settings增加一項 XXX device要求在quick settings中增加一項touch panel. 在/frameworks/base/packages/SystemUI/res/values/config.xml文件中的quick_settings_tiles_default string 中增加touch panel。並在String resource文件中增加顯示的title <!-- The def…