4

我想创建一个在我键入时使用 linq 搜索的任务，如果用户键入另一个字符，它应该取消任务并重新创建搜索，我有以下代码：

private Task SearchChannels;
private CancellationTokenSource cancelSearch;

public void PopulateChannels(string newValue)
{
    IsSearchingChannels = true; //This just shows a progressbar
    if (SearchChannels != null && cancelSearch!= null)
        if (SearchChannels.Status == TaskStatus.Running || 
            SearchChannels.Status == TaskStatus.WaitingToRun || 
            SearchChannels.Status == TaskStatus.WaitingForActivation || 
            SearchChannels.Status == TaskStatus.WaitingForChildrenToComplete) 
        {
            cancelSearch.Cancel();
            SearchChannels.Wait();
        }
    cancelSearch = new CancellationTokenSource();
    SearchChannels = new Task(() => Channels = new PagedObservableCollection<Channel>(ContractManager.Channels.Where(x => x.Name.ToLower().StartsWith(newValue)).AsParallel().WithCancellation(cancelSearch.Token).ToList()), cancelSearch.Token); //PagedObservableCollection is just a simple class with a list that keeps all items and an ObservableCollection for current items shown

    SearchChannels.Start();
    SearchChannels.ContinueWith((continuation) => IsSearchingChannels = false); // this just hides the progressbar when done
}

我得到这个例外：

'System.OperationCanceledException' 发生类型异常System.Core.dll但未在用户代码中处理

附加信息：操作已取消。

我是任务和取消令牌的初学者，有人可以从这里引导我走正确的道路吗？我基本上希望任务检查它是否已经运行，取消它，然后使用新值再次运行它（我想让这个“SearchBox”功能类似于 Visual Studio 在解决方案资源管理器中的搜索，它会在你输入时搜索）

4

1 回答 1

1

首先，您需要创建一个IObservable<string>抽象控件上的更改值。执行此操作的“最简单”方法是使用Subject<string>，但很可能是错误的方法。

下面是您应该放入 ViewModel 的代码。

IDisposable _searchSubscriber =
    _searchString
         .Buffer(TimeSpan.FromMillisecond(300))
         .Select(searchString => 
                Observable.StartAsync(cancelToken => 
                      Search(searchString, cancelToken)
                ).Switch()
         .ObserveOn(new DispatcherScheduler())
         .Subscribe(results => Channels = results);

public Task<List<Channel>> Search(string searchTerm, CancellationToken cancel)
{
    var query = dbContext.Channels.Where(x => x.Name.StartsWith(searchTerm));
    return query.ToListAsync(cancel);
}

private BehaviorSubject<string> _searchString = new BehaviorSubject<string>("");
public string SearchString
{
    get { return _searchString.Value; }
    set { _searchString.OnNext(value); OnPropertyChanged("SearchString"); }
}

Rx.net 是一个非常强大的库，这当然意味着它确实有一点学习曲线（尽管事实上这很复杂，因为你的问题很复杂）。

让我把它列出来...

.Buffer(TimeSpan.FromMilliseconds(300))消除您的查询的抖动，因此它仅每 300 毫秒运行一次查询。

Observable.StartAsync(cancelToken => Search(searchString, cancelToken))为搜索任务创建一个 Observable，当它被释放时将被取消。

Select(x => ...).Switch()只接受最新的查询结果，并处理最后一个查询。

ObserveOn(...)DispatchScheduler在使用的调度程序上运行以下命令，如果您正在使用，请确保您使用WPF，或者WinformsScheduler如果您使用 Winforms。

Subscribe(results => ...)对结果做点什么。

于 2014-08-12T14:03:21.713 回答