機能的には、ListView にバインドされた単語の長いリストがあります。文字の TextBox を使用して、単語のリストをフィルタリングします。
新しい文字では、処理中のバックグラウンド フィルターをキャンセルする必要があります。次に、1 秒 (DispatcherTimer) 待機して、新しいバックグラウンド並列フィルターを開始します。
BackGroundWorker を使用してこれを機能させますが、cancel-any-processing 部分を Parallel に変換することはできません。基本的に「if (backgroundWorkerFTSfilter.IsBusy) backgroundWorkerFTSfilter.CancelAsync();」が必要です。並行して。
私がこれについて間違っている場合は、私に知らせてください。
private List<FTSword> fTSwordsFiltered = new List<FTSword>();
CancellationTokenSource ftsCts = new CancellationTokenSource();
ParallelOptions ftspo = new ParallelOptions();
// in ctor ftspo.CancellationToken = ftsCts.Token;
public List<FTSword> FTSwordsFiltered // ListView bound to
{
get { return fTSwordsFiltered; }
set
{
if (fTSwordsFiltered == value) return;
fTSwordsFiltered = value;
NotifyPropertyChanged("FTSwordsFiltered");
}
}
public string FTSwordFilter // TextBox bound to
{
get { return fTSwordFilter; }
set
{
if (value == fTSwordFilter) return;
fTSwordFilter = value;
NotifyPropertyChanged("FTSwordFilter");
// cancel any filter currently processing
ftsCts.Cancel(); // fts filter
// with BackgroundWorker this was able to cancel
// if (backgroundWorkerFTSfilter.IsBusy) backgroundWorkerFTSfilter.CancelAsync();
dispatcherTimerFTSfilter.Stop();
// wait 1 second and apply filter in background
dispatcherTimerFTSfilter.Start();
}
}
private void dispatcherTimerFTSfilter_Tick(object sender, EventArgs e)
{
dispatcherTimerFTSfilter.Stop();
List<FTSword> ftsWords = new List<FTSword>();
//ftsCts = new CancellationTokenSource(); with these two it never cancels
//ftspo.CancellationToken = ftsCts.Token;
if (!(string.IsNullOrEmpty(FTSwordFilter)))
{
Task.Factory.StartNew(() =>
{
try
{
Parallel.ForEach(FTSwords, ftspo, ftsw =>
{
if (ftsw.WordStem.StartsWith(FTSwordFilter))
{
ftsWords.Add(ftsw);
}
ftspo.CancellationToken.ThrowIfCancellationRequested();
});
Thread.Sleep(1000); // so the next key stoke has time
FTSwordsFiltered = (List<FTSword>)ftsWords;
}
catch (OperationCanceledException ei)
{
// problem is that it is always cancelled from the cancel request before DispatchTimer
Debug.WriteLine(ei.Message);
}
Debug.WriteLine(ftsWords.Count.ToString() + "parallel ");
});
}
}
アーマンからの答えは私をこれに導きました
if (!(string.IsNullOrEmpty(FTSwordFilter)))
{
string startWorkFilter = FTSwordFilter;
Task.Factory.StartNew(() =>
{
try
{
fTSwordsFilteredCancel = false;
Parallel.ForEach(FTSwords, ftspo, (ftsw, loopstate) =>
{
if (ftsw.WordStem.StartsWith(startWorkFilter))
{
ftsWords.Add(ftsw);
}
// Thread.Sleep(1);
if (fTSwordsFilteredCancel)
{
loopstate.Break();
}
});
Debug.WriteLine("fTSwordsFilteredCancel " + fTSwordsFilteredCancel.ToString());
FTSwordsFiltered = (List<FTSword>)ftsWords;
Debug.WriteLine(ftsWords.Count.ToString() + " parallel " + startWorkFilter);
}
catch (OperationCanceledException ei)
{
Debug.WriteLine(ei.Message);
}
});
}
回答に非常に感謝しており、これを実行時間の長いタスクやリストの長いリストに使用しますが、パフォーマンスが非常に優れているため、これを get に移動しました (まだ 1 秒の遅延があります)。メモリ フットプリントが小さくなります。800,000 に対して 1/10 秒未満で実行されます。
public IEnumerable<FTSword> FTSwordsFiltered
{
get
{
if(string.IsNullOrEmpty(FTSwordFilter) || FTSwordFilter == "*") return FTSwords;
return FTSwords.AsParallel().Where(ftsWrd => ftsWrd.WordStem.StartsWith(FTSwordFilter));
}