在Linq内部创建IDisposable-异常安全

Question

我有类似于以下设置的东西：

class DisposableContainer : IDisposable
{
  IEnumerable<DisposableObject> items;
  //Potential problem method
  public void Populate(IEnumerable<OtherThings> things)
  {
    items = things.Select(thing => new DisposableObject(thing)); 
  }
  //IDisposable Implementation
  private bool disposed = false;
  ~DisposableContainer()
  {
    Dispose(false);
  }
  public override void Dispose()
  {
    Dispose(true);
    GC.SuppressFinalize(this);
  }
  private void Dispose(bool disposing)
  {
    if (!disposed)
    {
      if (disposing)
      {
        if (items != null)
        {
          items.Select(item => item.Dispose());
        }
      }
      disposed = true;
    }
  }
}

假设DisposableObject正确地实现了IDisposable，并且有一个接受OtherThing类型参数的构造函数。

假设在Populate方法中，如果select调用的第三次迭代引发异常，那么成功创建的前两个DisposableObject会发生什么？我认为它们会被泄露，并且保持原样。

后续问题：在仍然使用Linq生成IEnumerable<>的同时，是否有一种方法可以安全地处理上述场景？我无法预见，但我想把这个想法抛出去，看看是否有其他人有这个想法。

Answer 1

您的假设是正确的。已创建的DisposableObject将无法正确处理。

您可以使用一个临时列表来修复它，该列表包含创建的项目，并在需要时处理它们：

public void Populate(IEnumerable<OtherThings> things)
{
    var temp = new List<DisposableObject>();
    try
    {
        temp.AddRange(things.Select(otherThing => new DisposableObject(otherThing)));
        items = temp;
    }
    catch
    {
        foreach (var disposableObject in temp)
        {
            disposableObject.Dispose();
        }
        throw;
    }
}

这不能通过使用现有的Linq扩展方法来实现，但是可以（不建议这样做）添加自己的扩展方法：

public static IReadOnlyCollection<TDisposable> SelectDisposables<TItem, TDisposable>(
    this IEnumerable<TItem> enumerable, 
    Func<TItem,TDisposable> selector)
    where TItem : IDisposable
    where TDisposable : IDisposable
{
    var temp = new List<TDisposable>();
    try
    {
        temp.AddRange(enumerable.Select(selector));
        return temp;
    }
    catch
    {
        foreach (var disposable in temp)
        {
            disposable.Dispose();
        }
        throw;
    }
}

可以这样使用：

items = things.SelectDisposables(thing => new DisposableObject(thing));