持续取消Async CancellationTokenSource的最佳实践

Question

因此，我在我的UI上有一个组合框，它在SelectionChanged上异步退出到Web服务以撤回某些信息以在UI上显示（使用新的C＃5 async/await关键字）。我想要做的是在发送新的请求之前取消当前的异步请求;例如，如果用户使用键盘快速遍历所有组合框项目，则即使第一个异步请求返回，SelectionChanged事件也可能会多次触发（生成多个异步请求）。这会从组合框的SelectionChanged事件称为

所以我的异步函数如下所示：

public async Task<Connections> ConnectionsAsync() 
{ 
    return await Task.Factory.StartNew(() => Connections, _cancellationTokenSource.Token); 
} 

如果连接的是，熄灭并点击了Web服务的属性。所以，因为CancellationTokenSource不能重复使用，一旦取消，我想这样做的：

public async Task<Connections> ConnectionsAsync() 
{ 
    _cancellationTokenSource.Cancel(); 
    _cancellationTokenSource = new CancellationTokenSource(); 
    return await Task.Factory.StartNew(() => Connections, _cancellationTokenSource.Token); 
} 

的问题是，虽然有时候我会打电话取消（）时，有没有运行的异步命令（例如第一次这个函数被调用）;所以如果我连接任何取消事件处理程序，他们将被调用，甚至在我做出异步请求之前。

无论如何检查一个异步请求是否已经在运行？除了我做这样的事情：

public async Task<Connections> ConnectionsAsync() 
{ 
    if (_runningAsyncCommand) 
     _cancellationTokenSource.Cancel(); 
    _cancellationTokenSource = new CancellationTokenSource(); 
    _runningAsyncCommand = true; 
    return await Task.Factory.StartNew(() => Connections, _cancellationTokenSource.Token); 
    _runningAsyncCommand = false; 
} 

我有全部使用相同CancellationTokenSource一些异步函数，所以我就必须实现所有这些功能这个“管道”。这是最好的方法吗？或者，还有更好的方法？

另外，如果我公开地公开_cancellationTokenSource，以便其他类可以使用它注册取消委托，那么将这些委托“转移”到新的CancellationTokenSource的最佳方法是什么，因为我每次都创建一个新的CancellationTokenSource？

在此先感谢！

Answer 1

看起来像在天堂里为反应性扩展所做的配对。定义必须经过节流时间（比方说300毫秒）观察从ComboBox的事件时创建的任务

代码之前代码段订阅文本框更改事件，但你会得到的想法：

var input (from evt in Observable.FromEvent<EventArgs>(txt, "TextChanged") 
select ((TextBox)evt.Sender).Text) 
.Throttle(TimeSpan.FromSeconds(1)) 
.DistinctUntilChanged(); 

using (input.Subscribe(inp => Console.WriteLine("You wrote: " + inp))) 
{ 
    // Do stuff 
}