我有一个返回任务的方法,其中实现可能需要或可能不需要执行慢速操作才能检索结果.我希望能够将结果值简单地包装到一个任务中,该任务在值已经可用的情况下被标记为已经同步完成.今天我有这样的东西:
public Task<Foo> GetFooAsync(int key) { lock(this) { if(_Cache.ContainsKey(key) ) { Task<Foo> ret = new Task<Foo>(()=>_Cache[key]); ret.RunSynchronously(); return ret; } else { return Task.Factory.StartNew<Foo>(SomethingSlow()); } } }
有没有更简单的方法来做到这一点,当我已经知道结果时,不需要我使用委托来构建任务?
解决方法
你可以使用
TaskCompletionSource<TResult>
:
var tcs = new TaskCompletionSource<Foo>(); tcs.SetResult(_Cache[key]); return tcs.Task;
(请注意,如果_Cache是Dictionary< TKey,TValue>,您可以使用TryGetValue进行单次查找.)