首页 > 编程语言 >[转]一篇看懂C#中的Task任务_初级篇

[转]一篇看懂C#中的Task任务_初级篇

时间：2023-05-31 10:47:53浏览次数：50  
标签：Task thread created C# 635116412924607584 初级 data public

 

文章目录

 

一、前言

    在.NET平台使用C#进行编程时，遇到了并行操作的需求，于是上网一搜多线程，一个非常简单语句出现了：

Task.Factory.StartNew(() =>
{

});

还有，

Task.Run(() =>
{
});

    于是，拿来一用，往花括号中填入一些业务代码。
“嗯，确实是多线程。”
    我的印象中，在其他平台使用多线程都是先建一个线程对象，然后往里面填许多参数，然后还要手动启停。

	Thread thread = new Thread(p1, p2, func, 一堆看不懂的参数);
	thread.Start();
	...中间省略一万步
	thread.Abort();

    相比之下，.net平台这种极简的多线程操作方法对新手真是友好。（毕竟是微软的嘛，非常善于对底层复杂应用抽象，到应用层程序员这一侧，只管用就行了）。
    随着项目的进行，并行操作越来越复杂，我也愈来愈觉得不能就这么简单一用就完事了，得稍微了解下它的特性以及使用时的注意项。

二、认识

    于是上网搜了下C# Task使用，大部分都是翻译了一下微软官方文档里的东西（而且是自带的机翻）。那既然如此，我也试着结合官方文档来理解一下。
    下文出现的Task、task和任务基本上就是指一个东西，结合语境体会，不过一般首字母大写根据微软的习惯应该是表示类。

2.1. 基于任务的多线程编程

    Task并行库（就是你用Task这个东西的相关库，全名Task Parallel Library，简称TPL）是基于Task这个概念的，它代表了一个并行操作。也确实，如果你对一个不玩编程的人说某个线程xxx，人家可能听不懂，线程明显是个专业术语嘛；如果说任务，是不是感觉更贴近现实了呢。
    某种程度上来说，一个task类似于thread（线程）或者ThreadPool工作项（线程池的一项嘛，还是线程），但是它处在一个更高的抽象层面上（毕竟本质上还是线程嘛？大概吧）。
    接着，文档还亲民地解释了一下，“并行任务”这个术语指的是一个或者多个独立的任务同时进行。
    Task提供了两点基本的好处：

  • 更效率且更灵活的使用系统资源。
    在背后呢（通常说在底层实现上），任务是排在线程池当中的，并且它用了一些算法（决策、调整线程数量和提供了负载均衡以加大吞吐量）进行增强。这使得任务相对轻量级，你可以创建许多任务使得并行操作更精细化。
  • 相比使用线程或者线程池，有更多的程序模块可以使用。
    任务和平台框架（指.NET这个平台吧）提供了丰富的API支持waiting, cancellation, continuations, robust exception handling, detailed status, custom scheduling等功能。

    因此，对于在.NET上使用多线程、异步操作和并行代码的你来说，TPL是更好的API（也就是说，在.NET下，微软非常建议你使用Task）。
    看完这一段，很明显感觉到微软在说它好用，但是底层实现上是一笔带过的，就讲了它底层是用了线程池那一套的，并且有所优化（我开始有点理解，为什么大家都说，微软的东西好入门，但是难深入了。因为确实好用易上手，但是细节屏蔽太多了）。

2.2. 隐式地创建并运行一个任务

    Parallel.Invoke方法可以很便捷地让你同时运行任意数量的任意语句。仅仅需要为每个工作条目（item of work，或者说工作项）传递一个Action委托。创建这些委托最简单的方式是使用lambda表达式（这也是我一开始觉得task很简单的原因之一，因为不需要显示创建对象，用lambda就搞定了）。lambda表达式可以调用方法也可以添加代码行。下面的例子就展示了一个创建并启用两个同时运行任务的Invoke调用。

	Parallel.Invoke(() => DoSomeWork(), () => DoSomeOtherWork());

第一个任务表示通过lambda表达式调用了DoSomeWork方法，同理，第二个任务表示调用了DoSomeOtherWork。（温馨提示：如果你不了解lambda表达式，你可以先看看其他文章了解一下）。

备注：
由Invoke在底层创建的任务（Task）实例数量并不是一定与委托（Delegate）的数量相等的。
TPL可能会使用各种优化，尤其当有大量委托的时候。
 

    上面是一个隐式使用任务的例子，为了更好地控制任务的执行，你应该更明确地使用任务对象。

2.3. 显示地创建并运行一个任务

    用System.Threading.Tasks.Task类表示的任务不会返回值。用System.Threading.Tasks.Task<TResult>的任务会返回一个值，它继承自Task类。task对象处理基本的底层细节并提供了在任务生命周期内可由调用线程访问的方法和属性。例如，你可以在任意时刻访问任务的状态（Status）属性，以确定它是否在运行、是否运行完成、是否被取消或者是否抛出了异常。TaskStatus枚举描述了各种状态。
任务状态

2.3.1. Task常规使用

    当你创建一个任务时，你给它一个用户委托，该委托内封装了任务要执行的代码。这个委托可以是一个有命名的委托也可以是匿名的，还可以是lambda表达式。lambda表达式可以包含命名方法的调用，在下面的例子中予以展示。注意这个例子包含了一个Task.Wait方法的调用，用以确保任务在控制台模式结束前完成执行。

using System;
using System.Threading;
using System.Threading.Tasks;

public class Example
{
   public static void Main()
   {
      Thread.CurrentThread.Name = "Main";

      // Create a task and supply a user delegate by using a lambda expression.
      Task taskA = new Task( () => Console.WriteLine("Hello from taskA."));
      // Start the task.
      taskA.Start();

      // Output a message from the calling thread.
      Console.WriteLine("Hello from thread '{0}'.",
                        Thread.CurrentThread.Name);
      taskA.Wait();
   }
}
// The example displays output like the following:
//       Hello from thread 'Main'.
//       Hello from taskA.
 

2.3.2. Task.Run()

    你也可以使用Task.Run来一次性创建并启动一个任务。为了管理这个任务，Run方法使用了默认的任务调度器，无论这个任务调度器是否与当前线程相关。当你不需要对任务的创建和调度进行太多控制时，Run方法是更适用一些。（明显相对于上面的方式，Run将创建和启动合并为一步了）

	Task taskA = Task.Run(() => Console.WriteLine("Hello from taskA."));

2.3.3. Task.Factory.StartNew()

    你还可以使用TaskFactory.StartNew来一次性创建并启动一个任务。当创建和调度不必分离并且你需要额外的任务创建配置项或者使用特定的调度器，又或者你需要传递额外的状态到任务（你可以通过Task.AsyncState属性回收 ）中时，你可以使用TaskFactory.StartNew方法。下面是一个例子：

using System;
using System.Threading;
using System.Threading.Tasks;

class CustomData
{
	public long CreationTime;
	public int Name;
	public int ThreadNum;
}

public class Example
{
	public static void Main()
	{
		Task[] taskArray = new Task[10];
		for (int i = 0; i < taskArray.Length; i++)
		{
			taskArray[i] = Task.Factory.StartNew((object obj) => {
				CustomData data = obj as CustomData;
				if (data == null)
					return;
				data.ThreadNum = Thread.CurrentThread.ManagedThreadId;
			},
			new CustomData(){Name = i, CreationTime = DateTime.Now.Ticks});
		}
		Task.WaitAll(taskArray);
		foreach(var task in taskArray)
		{
			var data = task.AsyncState as CustomData;
			if (data != null)
				Console.WriteLine("Task #{0} created at {1}, ran on thread #{2}.",
                              data.Name, data.CreationTime, data.ThreadNum);
		}
	}
}
// The example displays output like the following:
//       Task #0 created at 635116412924597583 on thread #3.
//       Task #1 created at 635116412924607584 on thread #4.
//       Task #3 created at 635116412924607584 on thread #4.
//       Task #4 created at 635116412924607584 on thread #4.
//       Task #2 created at 635116412924607584 on thread #3.
//       Task #6 created at 635116412924607584 on thread #3.
//       Task #5 created at 635116412924607584 on thread #4.
//       Task #8 created at 635116412924607584 on thread #4.
//       Task #7 created at 635116412924607584 on thread #3.
//       Task #9 created at 635116412924607584 on thread #4.
 

2.3.4. 带有返回值的Task< TResult >

    Task和Task<TResult>都暴露了一个静态的Factory属性，该属性返回一个默认的TaskFactory实例，以便调用Task.Factory.StartNew()方法。同样，在下面的例子中，因为任务都是 System.Threading.Tasks.Task<TResult>类型的，它们都有一个 Task<TResult>.Result属性，该属性包含了运算的结果。任务是异步运行的，可能以任意时序执行完。若Result属性在运行结束前被访问，这个属性会阻塞调用线程直到该值可访问。

using System;
using System.Threading.Tasks;

public class Example
{
   public static void Main()
   {
        Task<Double>[] taskArray = { Task<Double>.Factory.StartNew(() => DoComputation(1.0)),
                                     Task<Double>.Factory.StartNew(() => DoComputation(100.0)),
                                     Task<Double>.Factory.StartNew(() => DoComputation(1000.0)) };

        var results = new Double[taskArray.Length];
        Double sum = 0;

        for (int i = 0; i < taskArray.Length; i++) {
            results[i] = taskArray[i].Result;
            Console.Write("{0:N1} {1}", results[i],
                              i == taskArray.Length - 1 ? "= " : "+ ");
            sum += results[i];
        }
        Console.WriteLine("{0:N1}", sum);
   }

   private static Double DoComputation(Double start)
   {
      Double sum = 0;
      for (var value = start; value <= start + 10; value += .1)
         sum += value;

      return sum;
   }
}
// The example displays the following output:
//        606.0 + 10,605.0 + 100,495.0 = 111,706.0
 

2.3.5. 结合lambda使用时出现的特殊情况

    当你使用lambda表达式创建一个委托时，你有权限访问在你源代码中此时可见的的所有变量。可是，在某些情况下，尤其是在循环中，一个lambda表达式无法如期捕获变量。它仅仅捕获了变量的引用，而不是每次迭代后发生变化的值（试着解释一下，任务的创建&启动需要时间大于循环执行完的事件，又因为任务委托中取得的是i的引用，所以委托真正执行时，循环已经执行完，引用去取出来的值都是最后的值了）。下面的例子说明了这个问题。它传递了一个循环计数器（int i）给lambda表达式，该表达式实例化了一个CustomData对象并使用了这个循环计数器作为对象的标识符。正如样例的输出展示的那样，每个CustomData对象都有完全一样的标识符，但这并不是你所期望的。

using System;
using System.Threading;
using System.Threading.Tasks;

class CustomData
{
   public long CreationTime;
   public int Name;
   public int ThreadNum;
}
public class Example
{
   public static void Main()
   {
      // Create the task object by using an Action(Of Object) to pass in the loop
      // counter. This produces an unexpected result.
      Task[] taskArray = new Task[10];
      for (int i = 0; i < taskArray.Length; i++) 
      {
         taskArray[i] = Task.Factory.StartNew( (Object obj) => {
         	var data = new CustomData() {Name = i, CreationTime = DateTime.Now.Ticks};
            data.ThreadNum = Thread.CurrentThread.ManagedThreadId;
            Console.WriteLine("Task #{0} created at {1} on thread #{2}.",
            	data.Name, data.CreationTime, data.ThreadNum);
         }, i);
      }
      Task.WaitAll(taskArray);
   }
}
// The example displays output like the following:
//       Task #10 created at 635116418427727841 on thread #4.
//       Task #10 created at 635116418427737842 on thread #4.
//       Task #10 created at 635116418427737842 on thread #4.
//       Task #10 created at 635116418427737842 on thread #4.
//       Task #10 created at 635116418427737842 on thread #4.
//       Task #10 created at 635116418427737842 on thread #4.
//       Task #10 created at 635116418427727841 on thread #3.
//       Task #10 created at 635116418427747843 on thread #3.
//       Task #10 created at 635116418427747843 on thread #3.
//       Task #10 created at 635116418427737842 on thread #4.
 

    在每次迭代时，你可以通过给任务的构造函数提供一个状态对象访问这该值。下面的样例程序通过在创建CustomData对象时使用循环计数器来修改了前面的例子，而CustomData对象又被传给了lambda表达式。正如样例输出的那样，现在每个CustomData对象都有唯一的基于循环计数器的标识符了。

using System;
using System.Threading;
using System.Threading.Tasks;

class CustomData
{
   public long CreationTime;
   public int Name;
   public int ThreadNum;
}
public class Example
{
   public static void Main()
   {
      // Create the task object by using an Action(Of Object) to pass in custom data
      // to the Task constructor. This is useful when you need to capture outer variables
      // from within a loop.
      Task[] taskArray = new Task[10];
      for (int i = 0; i < taskArray.Length; i++) {
         taskArray[i] = Task.Factory.StartNew( (Object obj ) => {
         	CustomData data = obj as CustomData;
            if (data == null)
            	return;
            data.ThreadNum = Thread.CurrentThread.ManagedThreadId;
            Console.WriteLine("Task #{0} created at {1} on thread #{2}.",
            	data.Name, data.CreationTime, data.ThreadNum);
         },
         new CustomData() {Name = i, CreationTime = DateTime.Now.Ticks} );
      }
      Task.WaitAll(taskArray);
   }
}
// The example displays output like the following:
//       Task #0 created at 635116412924597583 on thread #3.
//       Task #1 created at 635116412924607584 on thread #4.
//       Task #3 created at 635116412924607584 on thread #4.
//       Task #4 created at 635116412924607584 on thread #4.
//       Task #2 created at 635116412924607584 on thread #3.
//       Task #6 created at 635116412924607584 on thread #3.
//       Task #5 created at 635116412924607584 on thread #4.
//       Task #8 created at 635116412924607584 on thread #4.
//       Task #7 created at 635116412924607584 on thread #3.
//       Task #9 created at 635116412924607584 on thread #4.
 

    该状态作为一个参数传给了任务的委托，并且它能够被任务对象用Task.AsyncState属性访问。下面示例是上一个示例的变种。它使用了AsyncState属性来显示被传入到lambda表达式中的CustomData对象的信息。

using System;
using System.Threading;
using System.Threading.Tasks;

class CustomData
{
   public long CreationTime;
   public int Name;
   public int ThreadNum;
}
public class Example
{
   public static void Main()
   {
      Task[] taskArray = new Task[10];
      for (int i = 0; i < taskArray.Length; i++) 
      {
         taskArray[i] = Task.Factory.StartNew( (Object obj ) => {
         	CustomData data = obj as CustomData;
            if (data == null)
            	return;
            data.ThreadNum = Thread.CurrentThread.ManagedThreadId;
            },
            new CustomData() {Name = i, CreationTime = DateTime.Now.Ticks} );
      }
      Task.WaitAll(taskArray);
      foreach (var task in taskArray) {
         var data = task.AsyncState as CustomData;
         if (data != null)
            Console.WriteLine("Task #{0} created at {1}, ran on thread #{2}.",
                              data.Name, data.CreationTime, data.ThreadNum);
      }
   }
}
// The example displays output like the following:
//       Task #0 created at 635116412924597583 on thread #3.
//       Task #1 created at 635116412924607584 on thread #4.
//       Task #3 created at 635116412924607584 on thread #4.
//       Task #4 created at 635116412924607584 on thread #4.
//       Task #2 created at 635116412924607584 on thread #3.
//       Task #6 created at 635116412924607584 on thread #3.
//       Task #5 created at 635116412924607584 on thread #4.
//       Task #8 created at 635116412924607584 on thread #4.
//       Task #7 created at 635116412924607584 on thread #3.
//       Task #9 created at 635116412924607584 on thread #4.
 

三、总结

    归纳一下，task的几个特点：

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

    看了以上几个例子后，对task有个大致的了解，并且基本使用应该是没有太大问题了。但是文档往下翻，还有许多详细参数，细节方面的问题。必要时进行深入学习。

四、参考资料

微软文档

  转自https://blog.csdn.net/BadAyase/article/details/125006064

标签：Task,thread,created,C#,635116412924607584,初级,data,public
From： https://www.cnblogs.com/castlewu/p/17445366.html

相关文章

  • CentOS使用系统镜像搭建局域网Yum源
     一、防火墙配置CentOS7.x8.x默认使用的是firewall作为防火墙，这里改为iptables防火墙。1、关闭firewall：systemctlstopfirewalld.service#停止firewallsystemctldisablefirewalld.service#禁止firewall开机启动systemctlmaskfirewalldsystemctlstopfirew......
  • 1万多关数独逻辑游戏ACCESS\EXCEL数据库
    数独盘面是个九宫，每一宫又分为九个小格。在这八十一格中给出一定的已知数字和解题条件，利用逻辑和推理，在其他的空格上填入1-9的数字。使1-9每个数字在每一行、每一列和每一宫中都只出现一次，所以又称“九宫格”。每一关存储了81个数字，按顺序填入九宫格，数字0表示待填项，如下图所做示......
  • Spring：Formatter 和 ConversionService 的区别？
    在Spring框架中，Formatter和ConversionService是两个独立的概念，并没有直接的继承关系。Formatter接口和ConversionService接口是在不同的包中定义的，它们有着不同的目的和功能。Formatter接口位于org.springframework.format包中，用于格式化和解析字段值，并提供了本地化、格式化选项......
  • 2023第三届生物医学与生物信息工程国际学术会议 （ICBBE 2023） 南京
    2023第三届生物医学与生物信息工程国际学术会议（ICBBE2023）20233rdInternationalConferenceonBiomedicineandBioinformaticsEngineering会议时间：2023年6月16-18日会议地点：中国·南京截稿日期：2023年6月15日稿件反馈：投稿后1-2周内检索类型：EI，Scopus第三届生物医学与生......
  • 查看nebula版本号 console里show hosts graph
    (root@nebula)[(none)]>showhostsgraph+-------------+------+----------+---------+--------------+---------+|Host|Port|Status|Role|GitInfoSha|Version|+-------------+------+----------+---------+--------------+---------+|&q......
  • 神器vConsole！快速定位移动端问题，加快开发效率
    大家好，我是程序视点的小二哥!今天小二哥碰到一新来的实习生在使用alert调试H5页面，仿佛看到小二哥年少时羞涩的样子...趁这个机会，就给大家分享一个针对手机网页的前端开发者调试面板工具：vConsole简介vConsole是框架无关的，可以在Vue、React或其他任何框架中使用。现在vC......
  • vue中v-bind使用三目运算符绑定class
    <template><div><!--外边框的样式--><div:class="projectStatus===2?outlineDelay:outline"@click="clickProject(userProjectId)"><!--延期--><divv-if="projectStatus===2"......
  • yulong-hids 规则引擎，目前看到就是正则表达式和count技术
    规则项目提供的默认规则太简单和宽泛了，甚至包含一些错误，比如：有些不太精确，比如：另外规则引擎的匹配算法没有做优化，规则或者事件一旦多起来，server的负载会很高有些太宽泛导致误报非常高：agent在测试机才装2天就有近6w条告警，这是无法运营的，当然，规则支持细粒度控制（开关）还是很不错的3、功......
  • aspnetcore最最简单的接口权限认证
    五月一眨眼就过去，就当凑个数吧。场景：一个小小的项目，需要一个后台，就展示几个列表，连用户表、角色表等都不需要设计。之前有写过identityserver4和jwt4的demo(exercisebook/IdentityServer4&Serilogatmain·liuzhixin405/exercisebook·GitHubexercisebook/授权/授权一/Jw......
  • 方方格子excel汇总大师试用到期
    方方格子的excel汇总大师到期后，删除注册表分支即可：HKEY_CURRENT_USER\Software\VBandVBAProgramSettings\ExcelSummary\Regreg这个删除，再打开又是30天试用期。  摘自：https://zhidao.baidu.com/question/2273105751837667868.html......

赞助商

阅读排行

网站主页关于我们联系我们网站地图

本网站内容转载自其他媒体，侵权联系[admin##ips99.com]。

Copyright © 2020-2023 IPS99 版权所有 IPS99