如何使用任务有条件地异步运行代码

Question

我有一个负责检索资源的类，该类还缓存它们以便快速访问。 该类公开了用于检索资源的异步方法：

public Task<object> GetResourceAsync(string resourceName)
{
    return Task.Factory.StartNew<object>(() =>
    {
        // look in cache

        // if not found, get from disk

        // return resource
    });
}

客户端代码如下所示：

myResourceProvider.GetResourceAsync("myResource")
    .ContinueWith<object>(t => Console.WriteLine("Got resource " + t.Result.ToString()));

这样，始终使用后台线程。但是，如果在缓存中找到该对象，我不希望代码异步运行。 如果在缓存中找到它，我想立即返回资源，而不必使用另一个线程。

谢谢。

Answer 1

.NET 4.5 有 Task.FromResult 允许您返回 Task，但它不是在线程池线程上运行委托，而是显式设置任务的返回值。

因此，在您的代码上下文中：

public Task<object> AsyncGetResource(string resourceName)
{
    object valueFromCache;
    if (_myCache.TryGetValue(resourceName, out valueFromCache)) {
        return Task.FromResult(valueFromCache);
    }
    return Task.Factory.StartNew<object>(() =>
    {
        // get from disk
        // add to cache
        // return resource
    });
}

如果您仍在使用 .NET 4.0，则可以使用 TaskCompletionSource做同样的事情：

var tcs = new TaskCompletionSource<object>();
tcs.SetResult(...item from cache...);
return tcs.Task;

Answer 2

如果您有 UI 连接线程，请小心。

在 WPF 中，在 UI 线程（例如按钮单击事件处理程序）上使用 Task.Run 非常重要，以避免 UI 问题，并在后台线程上运行代码。

为什么？默认情况下，Task.Run 是 Task.Factory.StartNew 的包装器，带有 TaskScheduler.Default 参数，而不是 TaskScheduler.Current。

因此，仅仅像这样调用异步方法是不够的，因为它在 UI 线程上运行并冻结它： await SomeTaskAsync();

相反，您应该在 Task.Run 中调用它：

• < code>Task.Run(async() =>await SomeTaskAsync());

或者在 Task.Run 中使用同步方法：

• Task.Run(() =>; SomeTask());