8

这是这个问题的后续问题。

我正在尝试从我的数据库加载数据,这将需要 5-10 秒,但我希望 GUI 保持响应,并且它应该是可取消的。

private CancellationTokenSource _source;

public IEnumerable<Measurement> Measurements { get { ... } set { ... } }

private async void LoadData()
{
    _source = new CancellationTokenSource();

    using (var context = new TraceContext())
    {
        Measurements = null;
        Measurements = await context.Measurements.ToListAsync(_source.Token);
    }
}

private void Cancel()
{
    if (_source != null)
        _source.Cancel();
}

public RelayCommand ReloadCommand
{
    get { return _reloadCommand ?? (_reloadCommand = new RelayCommand(Reload)); }
}
private RelayCommand _reloadCommand;

public RelayCommand CancelCommand
{
    get { return _cancelCommand ?? (_cancelCommand = new RelayCommand(Cancel)); }
}
private RelayCommand _cancelCommand;

我已经尝试了一些事情,但我无法让它正常工作,这只是加载列表,仅此而已,我无法取消它。

这其中的错误在哪里?

4

1 回答 1

10

感谢您提出这个问题。目前,EF 中此异步 API 的实现依赖于底层 ADO.NET 提供程序来支持取消,但 SqlDataReader.ReadAsync 有一些限制,我们观察到在许多情况下,当请求取消时它不会立即取消。我们正在考虑在 EF6 RTM 中修复一个错误,该错误是关于引入我们自己的检查,以检查 EF 方法内的行读取之间的取消请求。

同时,您可以通过使用 ForEachAsync() 将项目添加到列表并检查每一行来解决此限制,例如(未彻底测试):

    public async static Task<List<T>> MyToListAsync<T>(
        this IQueryable<T> source,
        CancellationToken token)
    {
        token.ThrowIfCancellationRequested();
        var list = new List<T>();
        await source.ForEachAsync(item =>
        {
            list.Add(item);
            token.ThrowIfCancellationRequested();
        });
        return list;
    }
于 2013-08-06T18:49:07.473 回答