c# - 将 Task 转换为 Task 的最有效方法？

Question

我有一个高吞吐量的队列安排，我接受了一个 Func<Task>并希望将其转换到 Func<Task<System.Reactive.Unit>>很好地适应下游 Rx 系统。

自 Unit.Default是唯一的值(value)，感觉这应该很容易，但我希望它尽可能高效。我希望通过原始 Task 的所有异常以正确的方式。

我目前的做法是:

public Task<Unit> QueueTaskRx(Func<Task> task)
{
    Func<Task<Unit>> f = async () =>
    {
        await task();
        return Unit.Default;
    };

    return QueueTask(f);
}

但我担心 async/await 的开销

也许另一种更有效的方法是:

public Task<Unit> QueueTaskRx(Func<Task> task)
{
    Func<Task<Unit>> f = () => task().ContinueWith(_ =>
    {
        // What other cases do I need to consider here??
        if (_.IsFaulted && _.Exception != null)
            throw _.Exception.InnerException;

        return Unit.Default;
    }, TaskContinuationOptions.ExecuteSynchronously);

    return QueueTask(f);
}

但这并不安全，而且更复杂，分支等

有没有人有更好的方法？

Answer 1

我会使用async/await，同时添加一个ConfigureAwait(false)。

您可以使用 ContinueWith 来完成它，但这只会为您节省一些非常少的时间(比如单个按位标志检查和单个引用副本)。这将花费很多复杂性:

• ContinueWith 应始终指定一个 TaskScheduler。
• 除了异常之外，您还应该处理取消，因为 Task 会专门处理取消。

对于其他陷阱，请参阅我的 Tour of Task博客系列(遗憾的是仍然不完整)，我在其中尝试列举使用“旧”API 可能导致的所有问题(例如，ContinueWith)。