[c#] AsyncDispose에서 예외를 처리하는 올바른 방법

새로운 .NET Core 3으로 전환하는 동안 IAsynsDisposable다음과 같은 문제가 발생했습니다.

문제의 핵심 : DisposeAsync예외가 발생하면이 예외는 await using-block 내부에 발생한 예외를 숨 깁니다 .

class Program
{
    static async Task Main()
    {
        try
        {
            await using (var d = new D())
            {
                throw new ArgumentException("I'm inside using");
            }
        }
        catch (Exception e)
        {
            Console.WriteLine(e.Message); // prints I'm inside dispose
        }
    }
}

class D : IAsyncDisposable
{
    public async ValueTask DisposeAsync()
    {
        await Task.Delay(1);
        throw new Exception("I'm inside dispose");
    }
}

잡히면- AsyncDispose예외가 발생하고 예외가 await using발생 AsyncDispose하지 않는 경우에만 내부에서 예외가 발생 합니다 .

그러나 await using가능하면 블록 에서 예외를 가져오고 블록이 성공적으로 완료 된 DisposeAsync경우에만 -exception을 사용 하는 것이 좋습니다 await using.

이론적 근거 : 수업 D에서 일부 네트워크 리소스를 사용하고 일부 알림을 원격으로 구독 한다고 가정합니다 . 내부 코드 await using가 잘못하여 통신 채널에 장애가 생길 수 있습니다. 그 후 Dispose의 코드가 정상적으로 통신을 종료하려고 시도하면 (예 : 알림 수신 거부) 코드가 실패합니다. 그러나 첫 번째 예외는 문제에 대한 실제 정보를 제공하고 두 번째 예외는 단지 두 번째 문제입니다.

다른 경우에는 주요 부분이 통과되어 폐기가 실패한 경우 실제 문제는 내부 DisposeAsync에 있으므로 예외 DisposeAsync는 관련 문제입니다 . 즉, 내부의 모든 예외를 억제 DisposeAsync하는 것은 좋은 생각이 아닙니다.

나는 비 비동기 경우와 같은 문제가 있음을 알고있는 예외 finally재정의 예외 try, 그것을 던져하지 않는 것이 좋습니다 그 이유는 Dispose(). 그러나 네트워크 액세스 클래스를 사용하면 메소드 닫기에서 예외를 억제하는 것이 전혀 좋지 않습니다.

다음 도우미를 사용하여 문제를 해결할 수 있습니다.

static class AsyncTools
{
    public static async Task UsingAsync<T>(this T disposable, Func<T, Task> task)
            where T : IAsyncDisposable
    {
        bool trySucceeded = false;
        try
        {
            await task(disposable);
            trySucceeded = true;
        }
        finally
        {
            if (trySucceeded)
                await disposable.DisposeAsync();
            else // must suppress exceptions
                try { await disposable.DisposeAsync(); } catch { }
        }
    }
}

그리고 그것을 사용하십시오

await new D().UsingAsync(d =>
{
    throw new ArgumentException("I'm inside using");
});

그것은 추악한 것입니다 (그리고 using 블록 내부의 초기 반환과 같은 것을 허용하지 않습니다).

가능하면 좋은 정식 해결책이 await using있습니까? 인터넷에서 검색해도이 문제에 대해 논의하지 못했습니다.

답변

public static async Task<R> UsingAsync<T, R>(this T disposable, Func<T, Task<R>> task)
        where T : IAsyncDisposable
{
    bool trySucceeded = false;
    R result;
    try
    {
        result = await task(disposable);
        trySucceeded = true;
    }
    finally
    {
        if (trySucceeded)
            await disposable.DisposeAsync();
        else // must suppress exceptions
            try { await disposable.DisposeAsync(); } catch { }
    }
    return result;
}

try {
    throw new Exception("Inside try");
} finally {
    throw new Exception("Inside finally");
}

try {
    await using (var d = new D())
    {
        try
        {
            throw new ArgumentException("I'm inside using");
        }
        catch (Exception e)
        {
            Console.WriteLine(e.Message); // prints I'm inside using
        }
    }
} catch (Exception e) {
    Console.WriteLine(e.Message); // prints I'm inside dispose
}

var d = new D();
try
{
    throw new ArgumentException("I'm inside try");
}
catch (Exception e)
{
    Console.WriteLine(e.Message); // prints I'm inside try
}
finally
{
    try
    {
        if (D != null) await D.DisposeAsync();
    }
    catch (Exception e)
    {
        Console.WriteLine(e.Message); // prints I'm inside dispose
    }
}

class Program
{
    static async Task Main()
    {
        try
        {
            await using (var d = new D())
            {
                throw new ArgumentException("I'm inside using");
            }
        }
        catch (AggregateException ex)
        {
            ex.Handle(inner =>
            {
                if (inner is Exception)
                {
                    Console.WriteLine(e.Message);
                }
            });
        }
        catch (Exception e)
        {
            Console.WriteLine(e.Message);
        }
    }
}

class D : IAsyncDisposable
{
    public async ValueTask DisposeAsync()
    {
        await Task.Delay(1);
        throw new Exception("I'm inside dispose");
    }
}