EntLib TransientFaultHandling RetryPolicy.ExecuteAsync 同步上下文

Question

我在一个 Windows 8 应用商店应用程序中使用企业库瞬态故障处理应用程序块和用于 ODATA 的 WCF 数据服务客户端。我想对调用 ODATA 服务时发生的瞬态错误使用重试逻辑。我建立了一个自定义的瞬态错误检测策略。

我还为 DataServiceCollection 构建了一个 LoadTaskAsync 扩展方法，因为 LoadAsync 方法不返回任务（而是 DataServiceCollection 引发 LoadCompleted 事件）。

所以我可以将数据加载到 DataServiceCollection 中，如下所示：

var query = this.DataContext.Products.Where(item => item.Modified >= anchor);
var products = new DataServiceCollection<Product>(this.DataContext);
await this.retryPolicy.ExecuteAsync(() => products.LoadTaskAsync(query));

现在企业库瞬态故障处理应用程序块的文档指出

您传递给 ExecuteAsync 方法的 taskFunc 参数不一定在最初调用 ExecuteAsync 时使用的相同同步上下文中调用；因此，例如，如果您需要从 UI 线程中启动任务，请务必在委托中明确安排它。

我需要在 UI 线程上调用 LoadTaskAsync 方法，因为加载操作可能会更新已由数据上下文跟踪的产品以及数据绑定到 UI 的产品。

问题是怎么回事？最好不修改 LoadTaskAsync 扩展方法（如果不是我的代码要更改怎么办）。我正在考虑为调用 ExecuteAsync 方法的 RetryPolicy 创建一个扩展方法，同时确保在 UI 线程上调用 taskFunc。

最简单的方法可能是修改 LoadTaskAsync 扩展方法以传入 TaskCreationOptions.AttachedToParent，因此我可以为 RetryPolicy 创建扩展方法，如下所示：

    public static Task<TResult> ExecuteCurrentSynchronizationContextAsync<TResult>(
        this RetryPolicy retryPolicy, 
        Func<TaskCreationOptions, Task<TResult>> taskFunc)
    {
        var scheduler = TaskScheduler.FromCurrentSynchronizationContext();

        return
            retryPolicy.ExecuteAsync(
                () =>
                Task.Factory.StartNew(
                    () => taskFunc(TaskCreationOptions.AttachedToParent), 
                    CancellationToken.None, 
                    TaskCreationOptions.None, 
                    scheduler).Unwrap());
    }

请注意，taskFunc 现在必须是 Func>。

然后我会这样称呼它：

        await
            this.retryPolicy.ExecuteCurrentSynchronizationContextAsync(
                creationOptions => products.LoadTaskAsync(query, creationOptions));

由于我不想更改 LoadTaskAsync 扩展方法，我该如何更改此 RetryPolicy ExecuteCurrentSynchronizationContextAsync 扩展方法，以便在确保在 UI 线程上调用 taskFunc 的同时，taskFunc 可以再次成为 Func>？

Answer 1

我不建议将AttachedToParent 用于异步任务。事实上，大多数 Promise 风格的任务都会指定 DenyChildAttach which prevents AttachedToParent from working。

相反，您只需要捕获同步上下文本身并使用它。有一个问题：Windows 应用商店应用程序don't allow synchronous invocation on the synchronization context，因此您需要使用CoreDispatcher.RunAsync 而不是SynchronizationContext，或者为SynchronizationContext 构建自己的async-aware 扩展方法。在这两个中，我更喜欢使用SynchronizationContext 方法；在这种情况下，它的代码有点多，但这意味着您不必将您的代码（可能是服务层代码）绑定到这个特定的 UI 框架。

所以，首先我们在SynchronizationContext 上定义一个RunAsync，它将（异步）在指定的同步上下文中执行异步代码：

public static Task<TResult> RunAsync<TResult>(this SynchronizationContext context, Func<Task<TResult>> func)
{
    var tcs = new TaskCompletionSource<TResult>();
    context.Post(async _ =>
    {
        try
        {
            tcs.TrySetResult(await func());
        }
        catch (OperationCanceledException)
        {
            tcs.TrySetCanceled();
        }
        catch (Exception ex)
        {
            tcs.TrySetException(ex);
        }
    }, null);
    return tcs.Task;
}

然后我们可以捕获并使用SynchronizationContext：

public static Task<TResult> ExecuteOnCurrentSynchronizationContextAsync<TResult>(
    this RetryPolicy retryPolicy, 
    Func<Task<TResult>> taskFunc)
{
    var context = SynchronizationContext.Current ?? new SynchronizationContext();

    return retryPolicy.ExecuteAsync(() => context.RunAsync(taskFunc));
}