如何处理它在任务中创建的对象？

Question

我有一个foreach循环，创建这样的多任务：

[编辑：CreateDisposableAsync返回任务[IDisposable的]

foreach(...) 
{ 
    tasks.Add(CreateDisposableAsync()); 
} 

，后来我在等待着所有的这些任务，并捕获任何异常：

try 
{ 
    await Task.WhenAll(tasks); 
} 
catch (AggregateException) 
{ 
    // handle exceptions 
} 

但调用CreateDisposableAsync（）返回一个IDisposable的，这是我想被布置是否有在任何任务异常。我怎样才能做到这一点？

[编辑：原来，在CreateDisposableAsync（）函数处置其创建的对象，如果本身抛出异常，所以没有什么错的原始代码]

Answer 1

从评论

问：与放置，结果你做（或者希望做的）任何其他与结果调用代码

A的异常：无我不需要

最简单的方法是让CreateDisposableAsync方法在返回之前清理自己的资源并返回Task而不是Task<IDisposable>。 OP中显示的现有呼叫代码不必更改。

// change the signature 
async Task CreateDisposableAsync(){ 
    // use using blocks for anything that needs to be disposed 
    // try/finally is also acceptable 
    using(var someDisposableInstance = new SomethingDisposable()){ 
     // implementation 
    } 
} 

Answer 2

只有运行完成任务将已经返回可能被丢弃的物体。只需将列表筛选到完成的任务，然后选择结果即可。

try 
{ 
    try 
    { 
     await Task.WhenAll(tasks); 
    } 
    catch (AggregateException) 
    { 
     // handle exceptions 
    } 

    //do other stuff with the returned task objects. 
} 
finally 
{  
    foreach(var item in tasks.Where(x=>x.Status == TaskStatus.RanToCompletion).Select(x=>x.Result)) 
    { 
     //We use a try block so if Dispose throws it does not break the loop. 
     try 
     { 
      item.Dispose(); 
     } 
     catch(Exception ex) 
     { 
      //Log any exception on dispose. 
     } 
    } 
} 

或者，如果你不抛出错误不会返回对象WaitAll

try 
{ 
    await Task.WhenAll(tasks); 
} 
catch (AggregateException) 
{ 
    // handle exceptions 
} 
finally 
{  
    foreach(var item in tasks.Where(x=>x.Status == TaskStatus.RanToCompletion).Select(x=>x.Result)) 
    { 
     //We use a try block so if Dispose throws it does not break the loop. 
     try 
     { 
      item.Dispose(); 
     } 
     catch(Exception ex) 
     { 
      //Log any exception on dispose. 
     } 
    } 
} 

任务后，做其他任何工作计划，没有办法的CreateDisposableAsync()外弃掉，并如果出现任何错误，那么这个功能就有责任处理它们。

public async Task<MyDisposeableClass> CreateDisposableAsync() 
{ 
    MyDisposeableClass myDisposeableClass = null; 
    try 
    { 
     myDisposeableClass = new MyDisposeableClass(); 

     //... 

     return myDisposeableClass; 
    } 
    catch 
    { 
     //dispose of the class if the instance was created. 
     if(myDisposeableClass != null) 
      myDisposeableClass.Dispose(); 

     //let the execption bubble up. 
     throw; 
    } 
} 

Answer 3

我张贴这在这里，因为它似乎是一个替代的解决方案：

private static async Task CallCreateDisposableAsync() 
    { 
     using (await CreateDisposableAsync()) { } 
    } 

然后

foreach(...) 
{ 
    tasks.Add(CallCreateDisposableAsync); 
} 

这样using语句可配置所创建的IDisposable。