Jak poprawnie używać Task.WhenAll()

Question

Próbuję użyć Task.WhenAll, aby poczekać na zakończenie wielu zadań.

Mój kod jest poniżej - ma uruchomić wiele zadań asynchronicznych, z których każda pobiera trasę magistrali, a następnie dodaje je do lokalnej tablicy. Jednak Task.WhenAll (...) zwraca natychmiast, a liczba lokalnych tablic tras wynosi zero. Wydaje się to dziwne, ponieważ oczekiwałbym, że różne "oczekiwania" w każdym zadaniu oznaczają, że przepływ jest zawieszony, a zadanie nie powraca, dopóki nie zostanie zakończone.

 List<Task> monitoredTasks = new List<Task>(); 
     foreach (BusRouteIdentifier bri in stop.services) 
     { 
      BusRouteRequest req = new BusRouteRequest(bri.id); 

      // Start a new task to fetch the route for each stop 
      Task getRouteTask = Task.Factory.StartNew(async() => 
      { 
       var route = await BusDataProviderManager.DataProvider.DataBroker.getRoute(req); 

        // Add the route to our array (on UI thread as it's observed) 
        await dispatcher.RunAsync(Windows.UI.Core.CoreDispatcherPriority.Normal, delegate 
        { 
         this.routes.Add(route); 
        }); 
      }); 

      // Store the task in our monitoring list 
      monitoredTasks .Add(getRouteTask); 
     } 

     Debug.WriteLine("Awaiting WHENALL"); 
     await Task.WhenAll(monitoredTasks); 
     Debug.WriteLine(string.Format("WHENALL returned (routes count is {0} ", this.routes.Count)); 

     this.OnWillEndFetchingRoutes(new EventArgs()); 

Oczywiście robię coś nie tak - ale co?

Answer 1

ta spadła do podstawowego braku zrozumienia w jaki sposób asynchroniczny-czekają naprawdę działa.

Wewnętrznym zadaniem było przywrócenie przepływu do zewnętrznego zadania, które następnie zakończyło się przed oczekiwaniem na powrót.

Aby osiągnąć to, co chciałem, potrzebna byłaby następująco:

 List<Task<BusRoute>> routeRetrievalTasks = new List<Task<BusRoute>>(); 
     foreach (BusRouteIdentifier bri in stop.services) 
     { 
      BusRouteRequest req = new BusRouteRequest(bri.id); 
      routeRetrievalTasks.Add(BusDataProviderManager.DataProvider.DataBroker.getRoute(req)); 
     } 

     foreach (var task in routeRetrievalTasks) 
     { 
      var route = await task; 
      this.routes.Add(route); // triggers events 
     } 

Dzięki Dave Smits

Answer 2

Podejrzewam, że problem polega na połączeniu z numerem Task.Factory.StartNew(). Podejrzewam, że kończysz z Task<Task>, a dowiesz się tylko, kiedy to jest skuteczne.

Spróbuj to zamiast:

Func<Task> taskFunc = async() => 
{ 
    var route = await BusDataProviderManager.DataProvider.DataBroker.getRoute(req); 

    // Add the route to our array (on UI thread as it's observed) 
    await dispatcher.RunAsync(Windows.UI.Core.CoreDispatcherPriority.Normal, delegate 
    { 
     this.routes.Add(route); 
    }); 

} 

Task getRouteTask = Task.Run(taskFunc);