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

Question

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

[编辑：CreateDisposableAsync 返回一个任务[IDisposable]]

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

然后我等待所有这些任务，并捕获任何异常：

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

但是对 CreateDisposableAsync() 的调用会返回一个 IDisposable，无论任何任务中是否存在异常，我都希望将其处理掉。我该怎么做？

[编辑：事实证明，如果 CreateDisposableAsync() 函数抛出异常，它正在处理其创建的对象，因此原始代码没有任何问题。]

Answer 1

来自cmets

问：除了处理结果之外，您是否（或想要）在调用代码中对结果进行其他处理

答：不，我没有

最简单的方法是让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。