Abbrechen der vorherigen Async-Aufgabe mit CancellationTokenSource

Question

Ich muss async Task Abbrechen implementieren. Ich weiß, dass CancellationTokenSource mir dabei helfen würde. Aber ich finde keinen richtigen Weg.

Ich habe eine Suche Textbox, wann immer ein Benutzer in Textfeld für jede Textchanged-Ereignis I GetStocks Methode aufrufen, wie unten gezeigt,

public async Task GetStocks() 
{ 
    var stockings = new List<Services.Models.Admin.SiteStockingLevelsModel>(); 
    IsBusy = true; 
    cts?.Cancel(); 
    cts = new CancellationTokenSource(); 
    await Task.Run(() => { CreateStockingCollection(); }); 
    ValidateMaterials(); 
    IsBusy = false; 
} 

Die CreateStockingCollection Verfahren wird, wie unten gezeigt,

private void CreateStockingCollection() 
{ 
    var stockings = _siteStockingLevelsService.GetSiteInventoryLevels(SiteId); 
    CreateStockingLevelCompareCollection(stockings); 
    StockingLevels = 
     _mapper.Map<TrulyObservableCollection<SiteStockingLevelsModel>>(stockings);    

    ((INotifyPropertyChanged)StockingLevels).PropertyChanged += 
     (x, y) => CompareStockingChanges(); 
    CompareStockingChanges(); 
} 

Meine Anforderung hier ist
Beispiel Angenommen, Benutzer möchte "Abc" eingeben. Wenn der Benutzer "A" eingibt, wird die GetStocks Methode aufgerufen, der Benutzer gibt sofort "b" ein und die Methoden "get stocks" wird erneut aufgerufen. In diesem Fall möchte ich die vorherige GetStocks Aufgabe mit dem Buchstaben "A" abbrechen.

Answer 1

Stornierung ist kooperativ, so dass Sie Sie müssen geben sie es an Ihrem eigenen Code und haben es auf diesem Token antworten:

public async Task GetStocks() 
{ 
    var stockings = new List<Services.Models.Admin.SiteStockingLevelsModel>(); 
    IsBusy = true; 
    cts?.Cancel(); 
    cts = new CancellationTokenSource(); 
    var token = cts.Token; 
    await Task.Run(() => { CreateStockingCollection(token); }); 
    ValidateMaterials(); 
    IsBusy = false; 
} 

private void CreateStockingCollection(CancellationToken token) 
{ 
    var stockings = _siteStockingLevelsService.GetSiteInventoryLevels(SiteId, token); 
    CreateStockingLevelCompareCollection(stockings); 
    StockingLevels = 
     _mapper.Map<TrulyObservableCollection<SiteStockingLevelsModel>>(stockings);    

    ((INotifyPropertyChanged)StockingLevels).PropertyChanged += 
     (x, y) => CompareStockingChanges(); 
    CompareStockingChanges(); 
} 

Hier ist es zu GetSiteInventoryLevels ich vorbei, die so klingt, dass die lang andauernde Teil dieser Arbeit sein würde. GetSiteInventoryLevels muss jetzt die CancellationToken übernehmen und sie an die APIs weitergeben, die sie verwendet.

Answer 2

Eine der besten Praktiken der asynchronen Programmierung in .Net ist Async all the way. Es sieht so aus, als ob Ihre Methode nicht asyncbasiert ist. Sie akzeptiert auch keine CancellationToken. Sie müssen es zu Ihrer Methode hinzufügen, sonst wird nur Task.Run versuchen, Ihre Aufgabe abzubrechen, die nicht gut funktionieren würde.

Auch die einzige Schöpfung der CancellationTokenSource ist nicht genug - Sie brauchen .Token Eigenschaft es ist in Ihrem Code zu verwenden - das wäre genau das Token:

await Task.Run(() => { CreateStockingCollection(); }, cts.Token);