EntLib TransientFaultHandling RetryPolicy.ExecuteAsync同步上下文

Question

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

我还为LoadTaskAsync构建了一个DataServiceCollection扩展方法，因为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方法的ExecuteAsync参数不一定是在调用ExecuteAsync时使用的相同同步上下文中调用的；因此，如果您需要从UI线程中启动任务，请确保在委托中显式地调度它。

我需要在UI线程上调用LoadTaskAsync方法，因为load操作可能更新已经被数据上下文跟踪并绑定到UI的产品。

问题是怎么做的？最好不要修改LoadTaskAsync扩展方法(如果不是我的代码就可以更改)。我考虑为RetryPolicy创建一个扩展方法，该方法调用ExecuteAsync方法，同时确保在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扩展方法，以便taskFunc可以再次成为Func，同时确保在UI线程上调用taskFunc？

Answer 1

我不建议在异步任务中使用AttachedToParent。实际上，大多数承诺式的任务都会指定不工作。

相反，您只需要捕获同步上下文本身并使用它。有一个缺点: Windows应用程序不允许同步上下文上的同步调用，所以您需要使用CoreDispatcher.RunAsync而不是SynchronizationContext，或者为SynchronizationContext构建自己的async-aware扩展方法。在这两种方法中，我更喜欢使用SynchronizationContext方法；在本例中，代码要多一点，但这意味着您不必将代码(可能是服务层代码)绑定到这个特定的UI框架中。

因此，首先在RunAsync上定义一个SynchronizationContext，它将(异步)在指定的同步上下文上执行异步代码：

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));
}