如何检索 ValueTask 的异常？

Question

即将推出的 C# 8 IAsyncEnumerable 的设计使用 ValueTask 和 ValueTask<T> 将潜在的同步结果传达回消费者逻辑。它们都具有IsFaulted 属性，但与Task 不同的是，它们没有Exception 属性。

甚至可能有一个ValueTask 不包含正常的Task 并且处于故障或取消状态？

ValueTask<T>.Result 的文档表明在失败的任务上调用它会重新抛出包含的Exception。因此，以下代码对提取 Exception 有意义吗？

IAsyncEnumerable<int> asyncSequence = ...

ValueTask<bool> valueTask = asyncSequence.MoveNextAsync();

if (valueTask.IsFaulted) {
    // this has to work in a non-async method
    // there is no reason to block here or use the
    // async keyword
    try {
        var x = valueTask.Result;
    } catch (Exception ex) {
        // work with the exception
    }
}

ValueTask endTask = asyncSequence.DisposeAsync();

if (endTask.IsFaulted) {
    // there is no ValueTask.Result property
    // so the appoach above can't work
}

非泛型 ValueTask 没有 Result 属性。那么如何提取Exception呢？

一般来说，我认为应用AsTask 可以用于两种提取，但是，我认为它会导致分配，首先我理解ValueTask 的使用是有问题的。

Answer 1

在Task 或Task<T> 完成之前阻止的常用方法是调用Task.Wait() method。

如果抛出异常，它将是System.AggregatedException。 InnerExceptions property 将包含导致当前异常的异常集合。

从 .NET Framework 4.5 和 .NET Core 1.0 开始，还有 GetAwaiter() method，您可以在其中调用 GetResult() 的返回值，并将引发集合中的第一个异常。

但你永远不应该那样做！！！

你应该这样做：

// this has to work in a non-async method
try {
    var x = await valueTask;
} catch (Exception ex) {
    // work with the exception
}

ValueTask 和ValueTask<T> 用于避免在结果可能已经可用时进行堆分配。这并不意味着阻止该任务是安全的。

Answer 2

corefx team 的回复表明，这确实是不可能直接实现的，并且由于需要更改伴随界面而无法轻松添加，这会带来复杂性。

正如我最初猜测的那样，建议的解决方法是使用AsTask 来获取Exception。

IAsyncEnumerable<int> asyncSequence = ...

ValueTask<bool> valueTask = asyncSequence.MoveNextAsync();

if (valueTask.IsFaulted) {
    var ex = valueTask.AsTask().Exception;
    // work with the exception
}

ValueTask endTask = asyncSequence.DisposeAsync();

if (endTask.IsFaulted) {
    var ex = valueTask.AsTask().Exception;
    // work with the exception
}

Answer 3

最好的办法是使用 try 语句并尝试在那里捕获异常，然后再处理它... 对于不包含正常任务的 ValueTask，我认为您可以使用 lambda 方法来解决。

try {
    var x = Task.Run(()=>{ ... });
}
catch (Exception ex) {
    // Do something with exception.
}

或者不管 ValueTask 的情况如何。考虑到 C# 在过去的构建中大量关注异步任务，可以肯定地说您将使用 lambda 和事件调用。

private void foo(ValueTask task) {
        lock (threadObj) {
            var x = Task.Run(()=> { return task.doWork(); }
            if (x == true) {
                // then do other work...
            }
            else {
                // handle 'exception'...
            }
        }
}