我有一个高吞吐量的队列安排,我接受了一个 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);
}
但这并不安全,而且更复杂,分支等
有没有人有更好的方法?
最佳答案
我会使用async
/await
,同时添加一个ConfigureAwait(false)
。
您可以使用 ContinueWith
来完成它,但这只会为您节省一些非常少的时间(比如单个按位标志检查和单个引用副本)。这将花费很多复杂性:
ContinueWith
应始终指定一个TaskScheduler
。- 除了异常之外,您还应该处理取消,因为
Task
会专门处理取消。
对于其他陷阱,请参阅我的 Tour of Task
博客系列(遗憾的是仍然不完整),我在其中尝试列举使用“旧”API 可能导致的所有问题(例如,ContinueWith
)。
关于c# - 将 Task 转换为 Task<Unit> 的最有效方法?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/34333833/