标签:任务 start stat oid 创建 isp 通过 完成 rgs
前面介绍了Task的由来,以及简单的使用,包括开启任务,处理任务的超时、异常、取消、以及如果获取任务的返回值,在回去返回值之后,立即唤起新的线程处理返回值、且如果前面的任务发生异常,唤起任务如果有效的处理异常等关于Task的知识。所以本文将介绍Task更多的用法和特性.
一、如果通过一个任务创建多个子任务.
1、Task支持一个任务,创建多个子任务,并且保持关联.
static void Main(string[] args) { var parentTask = new Task<int[]>(() => { //开启多个子任务 var results = new int[2]; //创建子任务,并将子任务的值赋给results变量,并通过TaskCreationOptions.AttachedToParent,将其关联到父任务,如果不指定,该任务将独立于父任务单独执行 //这里有个奇怪的问题,只能使用new Task的方式去创建关联到父任务的子任务,因为Task.Run没有提供这个方法,可以通过扩展方法解决这个问题 new Task(() => results[0] = ChildThreadOne(), TaskCreationOptions.AttachedToParent).Start(); new Task(() => results[1] = ChildThreadTwo(), TaskCreationOptions.AttachedToParent).Start(); return results; }); parentTask.Start(); parentTask.ContinueWith(x => { Console.WriteLine("当父任务执行完毕时,CLR会唤起一个新线程,将父任务的返回值(子任务的返回值)输出,所以这里不会有任何的线程发生阻塞"); foreach (var re in parentTask.Result) { Console.WriteLine("子任务的返回值分别为:{0}", re); } }); Console.WriteLine("主线程不会阻塞,它会继续执行"); Console.ReadKey();//必须加这行代码,因为Task时线程池线程,属于后台线程 } /// <summary> /// 子任务一 /// </summary> static int ChildThreadOne() { Thread.Sleep(2000);//模拟长时间计算操作 Console.WriteLine("子任务一完成了计算任务,并返回值:{0}", 6); return 6; } /// <summary> /// 子任务一 /// </summary> static int ChildThreadTwo() { Thread.Sleep(2000);//模拟长时间计算操作 Console.WriteLine("子任务二完成了计算任务,并返回值:{0}", 6); return 6; }
二、关于Task的资源释放问题.
如果你看过Task的源码,你会发现下面这个有趣的问题:
ok,你会想它想释放什么呢?
没错,当Task任务,指定了TaskContinuationOptions枚举状态,且指定的值如下:
那么,直接return,什么资源释放操作都不做.
如果任务没有完成,就调用Dispose方法,那么直接抛异常,如果完成了,它就释放了ManualResetEventSlim信号量(后面的文章会介绍).所以如果你在task中使用了其它的一些非托管资源,那么最好在代码里自己手动释放,在使用完之后。或者自己实现了Task的派生类,把需要用的非托管资源加进去,然后在使用完派生类之后,调用Dispose方法.
三、关于Task的几个常用属性
1、Id属性,每个Task对象都有一个Id属性,全局唯一,且每次创建新的任务,这个值都会递增1.
2、TaskStatus状态
// // 摘要: // 表示 System.Threading.Tasks.Task 的生命周期中的当前阶段。 public enum TaskStatus { // // 摘要: // 该任务已初始化,但尚未被计划。 Created = 0, // // 摘要: // 该任务正在等待 .NET Framework 基础结构在内部将其激活并进行计划。 WaitingForActivation = 1, // // 摘要: // 该任务已被计划执行,但尚未开始执行。 WaitingToRun = 2, // // 摘要: // 该任务正在运行,但尚未完成。 Running = 3, // // 摘要: // 该任务已完成执行,正在隐式等待附加的子任务完成。 WaitingForChildrenToComplete = 4, // // 摘要: // 已成功完成执行的任务。 RanToCompletion = 5, // // 摘要: // 该任务已通过对其自身的 CancellationToken 引发 OperationCanceledException 对取消进行了确认,此时该标记处于已发送信号状态;或者在该任务开始执行之前,已向该任务的 // CancellationToken 发出了信号。 有关详细信息,请参阅任务取消。 Canceled = 6, // // 摘要: // 由于未处理异常的原因而完成的任务。 Faulted = 7 }
构造完Task对象是,状态为Created,当任务启动时,状态变为WaitingToRun,当Task实际在线程上运行时,状态变为Running.如果当前任务为父任务,且它已经执行完毕,等待其它子任务执行完毕的时候,其状态变为WaitingForChildrenToComplete.如果任务完成可能会出现以下几种状态:RanToCompletion(已成功完成执行的任务)、Canceled(取消状态)、
Faulted(任务出错).
这里需要注意一个特殊的状态WaitingForActivation
当使用Task对象的ContinueWith的Task对象处理改状态,意味者该Task任务的调度由任务基础结构控制.也就是该任务的调度只有当前面的任务执行完之后,由CLR发起执行调用.
标签:任务 start stat oid 创建 isp 通过 完成 rgs
原文地址:https://www.cnblogs.com/GreenLeaves/p/10051830.html