C# 同步方法调用终止当前处理

Question

我有一个ObservableCollection<string> 绑定到 WPF 视图。有一种方法可以刷新集合的内容。此方法在后台线程中处理，需要几秒钟。为避免错误，调用的方法是同步的。

即使之前的处理尚未完成，也可能会调用该方法。在这种情况下，我想停止当前的处理并开始新的处理。

private ObservableCollection<string> col = new ObservableCollection<string>();

private async void Refresh()
{
    var ui = TaskScheduler.FromCurrentSynchronizationContext();
    await Task.Factory.StartNew(() =>
        {
            return GetNewObjects();
        }).ContinueWith(t =>
        {
            col = t.Result;
        }, ui); 
}

[MethodImpl(MethodImplOptions.Synchronized)]
private ObservableCollection<string> GetNewObjects() 
{
    // processing
}

我的想法是在 Refresh() 中保存相应 Task 的引用，并检查每个调用，如果已经有正在运行的任务。这是停止任务的正确（和安全）方式吗？

Answer 1

您应该一直遵循async/await 路径。

要取消任务，请使用CancellationTokenSource 及其CancellationToken

private ObservableCollection<string> col = new ObservableCollection<string>();

private CancellationTokenSource _refreshCancellation;

private async void Refresh()
{
    // cancel the last Refresh action
    if ( _refreshCancellation != null )
    {
        _refreshCancellation.Cancel();
    }

    _refreshCancellation = new CancellationTokenSource();
    var token = _refreshCancellation.Token;

    try
    {
        var newObjects = await GetNewObjectsAsync( token );
        col = new ObservableCollection<string>( newObjects );
    }
    catch ( OperationCanceledException )
    {
    }

}

private async Task<ICollection<string>> GetNewObjectsAsync( CancellationToken cancellationToken )
{
    for ( int i = 0; i < 5; i++ )
    {
        await Task.Delay( 100 ).ConfigureAwait( false );
        // check if we had to cancel, but only where it is safe to cancel
        cancellationToken.ThrowIfCancellationRequested();
    }
    return new List<string> { "a", "b", "c", };
}