(译).NET4.X并行任务Task需要释放吗?

摘要:本博文解释在.NET 4.X中的Task使用完后为什么不应该调用Dispose()。并且说明.NET4.5对.NET4.0的Task对象进行的部分改进:减轻Task对WaitHandle对象的依赖,并且增强在释放了Task后对其成员的可访问性。

我多次获得这样一个问题:

“Task实现了IDisposable接口并且公开Dispose()方法,这是否意味着我们要对所有的任务进行释放吗?”

概述

  1. 这是我对该问题的简要回答:

“不是,不用释放你持有的Task。”

  1. 这是我对该问题的中篇回答:

“不是,不用释放你持有的Task,除非性能报告或可伸缩性测试报告显示你需要释放Task以满足你的性能目标。如果你发现一个需要被释放的Task,必须100%确保在你的释放点处该Task已经完成并且没有被其他地方在使用。”

  1. 下面,你可以找一个休闲的阅读时间,这是我对该问题的长回答:

为什么要调用Task的Dispose()?

.NET Framework设计指南中指出:一个类型如果持有其它实现过IDisposable接口的资源时,其自身也应该实现IDisposable接口。在Task内部,可能会分配一个WaitHandle对象用于等待任务完成。WaitHandle实现IDisposable接口因为它持有SafeWaitHandle内核等待句柄,所以Task实现了IDisposable接口。如果不主动释放SafeWaitHandle句柄,最终终结器也会将其清理,但是不能对此资源立即清理并且还将此清理工作负荷遗留给系统。通过给Task实现IDisposable接口,我们可以让开发人员能主动及时的对资源进行释放。

问题

如果为每一个Task都分配一个WaitHandle,那么释放Task将是一个好措施因为这样能提高性能。但是事实并非如此,现实中,为Task分配WaitHandle的情况是非常少出现的。在.NET 4.0中,WaitHandle在以下几种情况会延迟初始化:访问 ((IAsyncResult)task).AsyncWaitHandle成员,或者调用Task的WaitAll()/WaitAny()方法(这两个方法在.NET4.0版本中,内部是基于Task的WaitHandle对象实现的)。这使得回答“是否应该释放Task”问题更加困难了,因为如果Task都使用了WaitAll()/WaitAny(),那么释放Task就是一个好选择。

public interface IAsyncResult
{
    object AsyncState { get; }
    WaitHandle AsyncWaitHandle { get; }
    bool CompletedSynchronously { get; }
    bool IsCompleted { get; }
}

在.NET 4.0中,一个Task一旦被释放,它的大多数成员访问都会抛出ObjectDisposedExceptions异常。这使得完成的任务很难被安全的缓存,因为一个消费者释放Task后,另一个消费者无法再访问Task的一些重要成员,如ContinueWith()方法或Result属性。

这里还有另外一个问题:Task是基础同步基元。如果Task被用于并行化,如在一个fork/join模式(”分支/合并”模式)中那么它就很容易知道什么时候完成它们和什么时候没有人再使用它们,比如:

var tasks = new Task[3];
tasks[0] = Compute1Async();
tasks[1] = Compute2Async();
tasks[2] = Compute3Async();
Task.WaitAll(tasks);
foreach(var task in tasks) task.Dispose();

然而,当使用Task的延续任务时,就很难判断它什么时候完成它们和什么时候没有人再使用它们,比如:

Compute1Async().ContinueWith(t1 =>
{
    t1.Dispose();
    …
});

示例成功的释放掉Compute1Async()返回的Task,但是它忽略了如何释放ContinueWith()返回的Task。当然,我们能使用同样的方法释放这个Task。

Compute1Async().ContinueWith(t1 =>
{
    t1.Dispose();
    …
}).ContinueWith(t2 => t2.Dispose());

但是我们不能释放第二个ContinueWith()返回的Task。即使使用C#5.0中新的async/await异步方法也不能解决。例如:

string s1 = await Compute1Async();
string s2 = await Compute2Async(s1);
string s3 = await Compute3Async(s2);

如果想释放这些Task,我需要进行像下面这样的重写:

string s1 = null, s2 = null, s3 = null;
using(var t1 = Compute1Async())
    s1 = await t1;
using(var t2 = Compute2Async(s1))
    s2 = await t2;
using(var t3 = Compute3Async(s2))
    s3 = await t3;

解决方案

由于像上面这样进行释放大多数Task显得很繁琐,所以在.NET4.5中已经对Task的Dispose()做过一些改进:

  1. 我们使得你更少机会为Task创建WaitHandle对象。在.NET4.5中我们已经重写了Task的WaitAll()和WaitAny()以致这两个方法不再依赖与WaitHandle对象(这样WaitAll()、WaitAny()、Wait()就都基于自旋等待),避免在Task的内部实现中使用WaitHandle对象,并且提供async/await相关异步功能。因此,只有当你显示访问Task的IAsyncResult.AsyncWaitHandle成员才会为Task分配WaitHandle对象,但这种需求非常少见。这意味着除了这种非常少见的情况外,释放一个任务是不需要的。
  2. 我们使得Task在释放后依然可用。你能使用Task的所有公开成员即使Task已经被释放,访问这些成员的表现就和释放Task之前一样。只有IAsyncResult.AsyncWaitHandle成员你不能使用,因为这是你释放Task时真真所释放的对象,当你尝试在释放Task后访问这个属性时依然会抛出ObjectDisposedException。此外,更进一步的说,现在我们推荐使用async/await异步方法以及基于任务的异步编程模式,降低对IAsyncResult的使用,即使你继续使用((IAsyncResult)task),调用其AsyncWaitHandle成员也是十分罕见的。
  3. Task.Dispose()方法在“.NET Metro风格应用程序”框架所引用的程序集中甚至并不存在(即此框架中Task没有实现IDisposable接口)。

指南

所以,这又让我们回到了简要的回答:“不是,不用释放你的Task。”通常很难找到一个合适的释放点,目前几乎没有一个理由需要去主动释放Task(因为调用((IAsyncResult)task).AsyncWaitHandle成员的需求是十分罕见的),并且在“.NET Metro风格应用程序”框架所引用的程序集中你甚至不能调用Task的Dispose()方法。

更多资源来源博文:关于Async与Await的FAQ

时间: 2024-10-14 09:35:18

(译).NET4.X并行任务Task需要释放吗?的相关文章

.Net4.0 任务(Task)[转]

.Net4.0 任务(Task) 任务(Task)是一个管理并行工作单元的轻量级对象.它通过使用CLR的线程池来避免启动专用线程,可以更有效率的利用线程池.System.Threading.Tasks 命名空间下任务相关类一览: 类 作用 Task 管理工作单元 Task<TResult> 管理带返回值的工作单元 TaskFactory 创建任务 TaskFactory<TResult> 创建任务或者有相同返回值的延续任务 TaskScheduler 管理任务调度 TaskComp

.Net4.0 任务(Task)

.Net4.0 任务(Task),.net4.0任务task 任务(Task)是一个管理并行工作单元的轻量级对象.它通过使用CLR的线程池来避免启动专用线程,可以更有效率的利用线程池.System.Threading.Tasks 命名空间下任务相关类一览: 类 作用 Task 管理工作单元 Task<TResult> 管理带返回值的工作单元 TaskFactory 创建任务 TaskFactory<TResult> 创建任务或者有相同返回值的延续任务 TaskScheduler 管

Activity、Task、Application关系+Intent启动Flag

什么是Android  Application? 简单来说,一个apk文件就是一个Application. 任何一个AndroidApplication基本上是由一些Activities组成,当用户与应用程序交互时其所包含的部分Activities具有紧密的逻辑关系,或者各自独立处理不同的响应. 这些Activities捆绑在一起成为了一个处理特定需求的Application,并且以".apk"作为后缀名存在于文件系统中. Android平台默认下的应用程序 例如:Email.Cale

System.Threading.Tasks.Task引起的IIS应用程序池崩溃

问题现象 IIS应用程序池崩溃(Crash)的特征如下: 1. 从客户端看,浏览器一直处于连接状态,Web服务器无响应. 2. 从服务器端看(Windows Server 2008 + IIS 7.0),在事件日志中会出现Event ID为5010的错误: A process serving application pool 'q.cnblogs.com' failed to respond to a ping. The process id was '20080'. 这个错误的意思是:IIS检

System.Threading.Tasks.Task 任务引起的IIS应用程序池崩溃

转载:http://www.cnblogs.com/aaa6818162/p/4421305.html 问题现象 IIS应用程序池崩溃(Crash)的特征如下: 1. 从客户端看,浏览器一直处于连接状态,Web服务器无响应. 2. 从服务器端看(Windows Server 2008 + IIS 7.0),在事件日志中会出现Event ID为5010的错误: A process serving application pool 'q.cnblogs.com' failed to respond

spark总结——转载

转载自:http://smallx.me/2016/06/07/spark%E4%BD%BF%E7%94%A8%E6%80%BB%E7%BB%93/ 第一个Spark程序 /** * 功能:用spark实现的单词计数程序 * 环境:spark 1.6.1, scala 2.10.4 */ // 导入相关类库import org.apache.spark._ object WordCount { def main(args: Array[String]) { // 建立spark运行上下文 val

Net Core WebAPI

Net Core WebAPI .Net Core WebAPI 基于Task的同步&异步编程快速入门 Task.Result async & await 总结 并行任务(Task)以及基于Task的异步编程(asynchronously)在.NET Framework早已使用多年,而在微软新推出的.NET Core 平台下也有相同功能的实现,本文将通过.NET Core WebAPI,介绍使用Task.result的同步编程以及使用await的异步编程模型. Task.Result Re

c# .net 3.5 4.0 4.5 5.0 6.0各个版本新特性战略规划总结【转载】

引用:http://blog.csdn.net/attilax/article/details/42014327 c# .net 3.5 4.0 各个版本新特性战略规划总结 1. --------------.Net Framework版本同CLR版本的关系1 2. paip.------------SDK2.0功能-------------2 2.1. 泛型:2 3. --------------sdk3.0  增加了以下功能..2 3.1. LINQ 3 4.  ----------sdk4

Spark学习笔记总结-入门资料精化

Spark简介 spark 可以很容易和yarn结合,直接调用HDFS.Hbase上面的数据,和hadoop结合.配置很容易. spark发展迅猛,框架比hadoop更加灵活实用.减少了延时处理,提高性能效率实用灵活性.也可以与hadoop切实相互结合. spark核心部分分为RDD.Spark SQL.Spark Streaming.MLlib.GraphX.Spark R等核心组件解决了很多的大数据问题,其完美的框架日受欢迎.其相应的生态环境包括zepplin等可视化方面,正日益壮大.大型公